C#/C++ 通过ODBC连接OceanBase Oracle租户的详细过程

更新时间：2024年05月07日 08:55:06 作者：sirius_mchao

近期我们项目正处于将Oracle数据库迁移到OceanBase Oracle租户模式的阶段,考虑到我们项目采用了C++和C#混合开发,并且使用了多种技术,因此存在多种数据库连接方式,C#连接OceanBase的案例相对较少,因此我特意记录下这一过程,感兴趣的朋友一起看看吧

概述

近期我们项目正处于将Oracle数据库迁移到OceanBase Oracle租户模式的阶段。考虑到我们项目采用了C++和C#混合开发，并且使用了多种技术，因此存在多种数据库连接方式。然而，针对C#连接OceanBase的案例相对较少，因此我特意记录下这一过程。

开放数据库互连（ODBC）是微软公司开放服务结构（WOSA，Windows Open Services Architecture）中有关数据库的一个组成部分，基本思想是为用户提供简单、标准、透明的数据库连接的公共编程接口，开发厂商根据 ODBC 的标准去实现底层的驱动程序，这个驱动对用户是透明的，并允许根据不同的 DBMS 采用不同的技术加以优化实现。

驱动下载

下载地址：https://www.oceanbase.com/softwarecenter-cloud

根据平台类型选择驱动。

驱动配置

打开 ODBC 数据源管理员：在 Windows 中，按下 Windows键 + R 打开“运行”对话框，然后输入 odbcad32 并按下 Enter 键，这将打开 ODBC 数据源管理员。

选择系统的或用户的数据源：在 ODBC 数据源管理员中，有两个选项卡：用户 DSN 和系统 DSN。选择一个适合你的选项，通常建议选择系统 DSN，因为它对所有用户都可用。

添加一个新的数据源：点击添加按钮，然后在弹出的对话框中选择 OceanBase ODBC 2.0 Driver 数据库。

配置数据源连接信息：在配置 OceanBase 数据库数据源时，你需要提供以下信息：

数据源名称（DSN）：为你的数据源指定一个唯一的名称。这里命名为OceanBase ODBC

描述：提供有关此数据源的描述，以便识别它。

TNS 服务名称：输入你要连接的 Oracle 服务的 TNS 服务名称。IP： XX.XX.XX.XX

用户名和密码：提供用于连接到 Oracle 数据库的用户名和密码。

UserName: 用户名@租户名#集群

测试连接：在完成配置后，你可以点击测试连接按钮来验证是否能够成功连接到 OceanBase Oracle 数据库。

注意：不通过DSN也可以连接

C++ 代码案例

#include <stdio.h>
#include <assert.h>
#include <windows.h>
#include <sql.h>
#include <sqlext.h>
#include <iostream>
void print_error(SQLSMALLINT HandleType, SQLHANDLE Handle) {
    SQLWCHAR SQLState[6];
    SQLINTEGER NativeError;
    SQLWCHAR SQLMessage[SQL_MAX_MESSAGE_LENGTH] = { 0 };
    SQLSMALLINT TextLengthPtr;
    SQLGetDiagRec(HandleType, Handle, 1, SQLState, &NativeError, SQLMessage, SQL_MAX_MESSAGE_LENGTH, &TextLengthPtr);
    std::wcerr << L"[" << SQLState << L"] (" << NativeError << L") " << SQLMessage << std::endl;
}
int main() {
    // Allocate environment handle
    SQLHANDLE henv;
    SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);
    SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3, 0);
    // Allocate connection handle
    SQLHANDLE hdbc;
    SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);
    // Connection string
    //使用DSN
    SQLWCHAR* connectionString = (SQLWCHAR*)L"DSN=OceanBase ODBC;UID=用户名@住户名#集群;PWD=密码";
    //不使用DSN
    //SQLWCHAR* connectionString = (SQLWCHAR*)L"Driver={OceanBase ODBC 2.0 Driver};Server=xx.xx.xx.xx;Port=2883;Database=用户名;User=用户名@住户名#集群;Password=密码;Option=3;";
    // Connect to the database
    SQLRETURN retcode = SQLDriverConnect(hdbc, NULL, connectionString, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_NOPROMPT);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        std::cerr << "Error connecting to database:" << std::endl;
        print_error(SQL_HANDLE_DBC, hdbc);
        return 1;
    }
    std::cout << "Connected to database successfully!" << std::endl;
    // Allocate statement handle
    SQLHANDLE hstmt;
    SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);
    // Execute a query
    SQLWCHAR* query = (SQLWCHAR*)L"SELECT * FROM TIERS WHERE ROWNUM <= 1;";
    retcode = SQLExecDirect(hstmt, query, SQL_NTS);
    if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO) {
        std::cerr << "Error executing query:" << std::endl;
        print_error(SQL_HANDLE_STMT, hstmt);
        SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
        SQLDisconnect(hdbc);
        SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
        SQLFreeHandle(SQL_HANDLE_ENV, henv);
        return 1;
    }
    // Fetch and print results
    SQLCHAR name[256];
    SQLLEN nameLen;
    while (SQLFetch(hstmt) == SQL_SUCCESS) {
        SQLGetData(hstmt, 1, SQL_C_CHAR, name, sizeof(name), &nameLen);
        std::cout << "Name: " << name << std::endl;
    }
    // Cleanup
    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);
    SQLDisconnect(hdbc);
    SQLFreeHandle(SQL_HANDLE_DBC, hdbc);
    SQLFreeHandle(SQL_HANDLE_ENV, henv);
    return 0;
}

C# 代码案例

using System;
using System.Data.Odbc;
namespace ConsoleApp
{
    internal class Program
    {
        static void Main(string[] args)
        {
            //使用DSN
            string connectionString = "DSN=OceanBase ODBC;Uid=用户名@住户名#集群;Pwd=你的密码;";
            //不使用DSN
            //string connectionString = "Driver={OceanBase ODBC 2.0 Driver};Server=xx.xx.xx.xx;Port=2883;Database=用户名;User=用户名@住户名#集群;;Password=密码;Option=3;";
            using (OdbcConnection connection = new OdbcConnection(connectionString))
            {
                try
                {
                    connection.Open();
                    Console.WriteLine("Connected to Oracle database!");
                    // Perform database operations here
                    string query = "SELECT *FROM TIERS WHERE ROWNUM <= 1;";
                    using (OdbcCommand command = new OdbcCommand(query, connection))
                    {
                        using (OdbcDataReader reader = command.ExecuteReader())
                        {
                            while (reader.Read())
                            {
                                int id = reader.GetInt32(0); // 假设第一列是 ID
                                string name = reader.GetString(1); // 假设第二列是 Name
                                Console.WriteLine($"ID: {id}, Name: {name}");
                            }
                        }
                    }
                    connection.Close();
                }
        }
    }
}

NHibernate示例

安装NHibernate

使用NuGet包管理器安装NHibernate。你可以在Visual Studio中打开NuGet包管理器控制台，然后运行以下命令：

Install-Package NHibernate

这将自动下载并安装NHibernate及其所有依赖项到你的项目中。

配置NHibernate

NHibernate.cfg.xml

<hibernate-configuration xmlns="urn:nhibernate-configuration-2.2">
    <session-factory>
        <property name="connection.driver_class">NHibernate.Driver.OdbcDriver</property>
        <!--<property name="connection.connection_string">DSN=OceanBase ODBC;Database=用户名;Uid=用户名@住户名#集群;Pwd=密码;</property>-->
        <property name="connection.connection_string">Driver={OceanBase ODBC 2.0 Driver};Server=xx.xx.xx.xx;Port=2883;Database=用户名;Uid=用户名@住户名#集群;Pwd=密码;</property>
        <property name="dialect">NHibernate.Dialect.Oracle10gDialect</property>
    </session-factory>
</hibernate-configuration>

配置映射类

public class TestEntity
{
    public virtual int Ident { get; set; }
    public virtual string Name { get; set; }
}

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2">
    <class name="ConsoleApp2.TestEntity, ConsoleApp2" table="TESTENTITY">
        <id name="Ident" column="IDENT" />
        <property name="Name" column="NAME" />
        <!-- 其他属性映射... -->
    </class>
</hibernate-mapping>

查询案例

using NHibernate.Cfg;
using System;
using System.IO;
class Program
{
    static void Main(string[] args)
    {
        string baseDirectory = AppDomain.CurrentDomain.BaseDirectory;
        var cfg = new Configuration().Configure(Path.Combine(baseDirectory, "NHibernate.cfg.xml"));
        cfg.AddFile(Path.Combine(baseDirectory, "TestEntity.xml"));
        var sessionFactory = cfg.BuildSessionFactory();
        using (var session = sessionFactory.OpenSession())
        {
            var query = session.CreateQuery("FROM TestEntity")
                .SetMaxResults(10);
            var results = query.List();
        }
    }
}

到此这篇关于C#/C++ 通过ODBC连接OceanBase Oracle租户的文章就介绍到这了,更多相关C++ 连接OceanBase Oracle租户内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

基于多态之虚方法、抽象类、接口详解
下面小编就为大家分享一篇基于多态之虚方法、抽象类、接口详解，具有很好的参考价值。希望对大家有所帮助。一起跟随小编过来看看吧
2017-11-11
C# 中文简体转繁体实现代码
C# 中文简体转繁体实现代码，需要的朋友可以参考一下
2013-02-02
C# WPF如何反射加载Geometry几何图形数据图标
这篇文章主要介绍了C# WPF如何反射加载Geometry几何图形数据图标，帮助大家更好的理解和学习使用c#，感兴趣的朋友可以了解下
2021-03-03
C# 绘制实时折线图，波形图
这篇文章主要介绍了C# 绘制实时折线图，波形图的方法，文中示例代码非常详细，帮助大家更好的理解和学习，感兴趣的朋友可以了解下
2020-07-07
Unity实现图形相交检测
这篇文章主要为大家详细介绍了Unity实现图形相交检测，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2020-04-04
C#自定义音乐播放器进度条
这篇文章主要为大家详细介绍了C#自定义音乐播放器进度条效果，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-07-07
C#利用栈实现加减乘除运算
这篇文章主要介绍了C#利用栈实现加减乘除运算的实现方法,需要的朋友可以参考下
2019-11-11
C#动态绘制多条曲线的方法
这篇文章主要为大家详细介绍了C#动态绘制多条曲线的方法，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-02-02
c#高效比对大量图片的实例代码
以前传统的比较方式是遍历图片中的每一个像素，然后进行比对。这样的比对在少量图片的比对上虽然效率低一点，但是也没有什么不好。但是在大量图片比对的时候，过长的反应时间和对服务器比较高的消耗肯定是不行的，下面介绍下新的方法
2013-10-10
c#使用netmail方式发送邮件示例
这篇文章主要介绍了c#使用netmail方式发送邮件的示例，大家参考使用吧
2014-01-01