--- title: "数据库驱动 | OceanBase 文档中心" description: 数据库驱动 在 OceanBase 数据库 MySQL 模式下，用户可以直接使用 MySQL 官方提供的 Connector 来使用 OceanBase 数据库，在 OceanBase 数据库 Oracle 模式下，需要使用 OceanBase 自研的数据库驱动。OceanBase 数据库驱动同时支持 OceanBa… --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 2.2.30 企业版 # 数据库驱动 更新时间：2024-10-08 15:20:36 在 OceanBase 数据库 MySQL 模式下，用户可以直接使用 MySQL 官方提供的 Connector 来使用 OceanBase 数据库，在 OceanBase 数据库 Oracle 模式下，需要使用 OceanBase 自研的数据库驱动。OceanBase 数据库驱动同时支持 OceanBase 数据库的 MySQL/Oracle 两种协议，在使用时可以自动识别 OceanBase 数据库的运行模式是 MySQL 还是 Oracle，无需额外设置。OceanBase 数据库支持各类语言的数据库驱动，下面介绍几种常见的语言及标准。 ## OCI 驱动 OceanBase 提供了基于 OCI 接口的数据库驱动，兼容了 Oracle 数据库 OCI 接口的方法名和函数名，对于试用 OCI 接口编程的应用程序在进行移植时，无需做大量业务改造即可非常方便的适配到 OceanBase 数据库。 样例代码： ```code #include #include #include #include #include "oci.h" /*声明句柄*/ OCIEnv *envhp; /*环境句柄*/ OCISvcCtx *svchp; /*服务环境句柄*/ OCIServer *srvhp; /*服务器句柄*/ OCISession *authp; /*会话句柄*/ OCIStmt *stmthp; /*语句句柄*/ OCIDescribe *dschp; /*描述句柄*/ OCIError *errhp; /*错误句柄*/ OCIDefine *defhp[3]; /*定义句柄*/ OCIBind *bidhp[4]; /*绑定句柄*/ sb2 ind[3]; /*指示符变量*/ /*绑定select结果集的参数*/ text szpersonid[9]; /*存储personid列*/ text szsex[2]; /*存储sex列*/ text szname[51]; /*存储name列*/ text szemail[51]; /*存储mail列*/ text szphone[26]; /*存储phone列*/ char sql[256]; /*存储执行的sql语句*/ int main(int argc, char *argv[]) { char strServerName[50]; char strUserName[50]; char strPassword[50]; /*设置服务器，用户名和密码*/ strcpy(strServerName, "host:port/db"); strcpy(strUserName, "user"); strcpy(strPassword, "pwd"); /*初始化OCI应用环境*/ OCIInitialize(OCI_DEFAULT, NULL, NULL, NULL, NULL); /*初始化环境句柄*/ OCIEnvInit(&envhp, OCI_DEFAULT, 0, 0); /*分配句柄*/ OCIHandleAlloc(envhp, (dvoid **)&svchp, OCI_HTYPE_SVCCTX, 0, 0); /*服务器环境句柄*/ OCIHandleAlloc(envhp, (dvoid **)&srvhp, OCI_HTYPE_SERVER, 0, 0); /*服务器句柄*/ OCIHandleAlloc(envhp, (dvoid **)&authp, OCI_HTYPE_SESSION, 0, 0); /*会话句柄*/ OCIHandleAlloc(envhp, (dvoid **)&errhp, OCI_HTYPE_ERROR, 0, 0); /*错误句柄*/ OCIHandleAlloc(envhp, (dvoid **)&dschp, OCI_HTYPE_DESCRIBE, 0, 0); /*描述符句柄*/ /*连接服务器*/ OCIServerAttach(srvhp, errhp, (text *)strServerName, (sb4)strlen(strServerName), OCI_DEFAULT); /*设置用户名和密码*/ OCIAttrSet(authp, OCI_HTYPE_SESSION, (text *)strUserName, (ub4)strlen(strUserName), OCI_ATTR_USERNAME, errhp); OCIAttrSet(authp, OCI_HTYPE_SESSION, (text *)strPassword, (ub4)strlen(strPassword), OCI_ATTR_PASSWORD, errhp); /*设置服务器环境句柄属性*/ OCIAttrSet((dvoid *)svchp, (ub4)OCI_HTYPE_SVCCTX, (dvoid *)srvhp, (ub4)0, OCI_ATTR_SERVER, errhp); OCIAttrSet(svchp, OCI_HTYPE_SVCCTX, (dvoid *)authp, 0, OCI_ATTR_SESSION, errhp); /*创建并开始一个用户会话*/ OCISessionBegin(svchp, errhp, authp, OCI_CRED_RDBMS, OCI_DEFAULT); OCIHandleAlloc(envhp, (dvoid **)&stmthp, OCI_HTYPE_STMT, 0, 0); /*语句句柄*/ /************************************************************************/ /*查询person表*/ /************************************************************************/ strcpy(sql, "select personid ,name,phone from person"); /*准备SQL语句*/ OCIStmtPrepare(stmthp, errhp, (text *)sql, strlen(sql), OCI_NTV_SYNTAX, OCI_DEFAULT); /*绑定输出列*/ OCIDefineByPos(stmthp, &defhp[0], errhp, 1, (ub1 *)szpersonid, sizeof(szpersonid), SQLT_STR, &ind[0], 0, 0, OCI_DEFAULT); OCIDefineByPos(stmthp, &defhp[1], errhp, 2, (ub1 *)szname, sizeof(szname), SQLT_STR, &ind[1], 0, 0, OCI_DEFAULT); OCIDefineByPos(stmthp, &defhp[2], errhp, 3, (ub1 *)szphone, sizeof(szphone), SQLT_STR, &ind[2], 0, 0, OCI_DEFAULT); /*执行SQL语句*/ OCIStmtExecute(svchp, stmthp, errhp, (ub4)0, 0, NULL, NULL, OCI_DEFAULT); printf("%-10s%-10s%-10s\n", "PERSONID", "NAME", "PHONE"); while ((OCIStmtFetch(stmthp, errhp, 1, OCI_FETCH_NEXT, OCI_DEFAULT)) != OCI_NO_DATA) { printf("%-10s, %-10s,%-10s\n", szpersonid, szname, szphone); } //结束会话 OCISessionEnd(svchp, errhp, authp, (ub4)0); //断开与数据库的连接 OCIServerDetach(srvhp, errhp, OCI_DEFAULT); //释放OCI句柄 OCIHandleFree((dvoid *)dschp, OCI_HTYPE_DESCRIBE); OCIHandleFree((dvoid *)stmthp, OCI_HTYPE_STMT); OCIHandleFree((dvoid *)errhp, OCI_HTYPE_ERROR); OCIHandleFree((dvoid *)authp, OCI_HTYPE_SESSION); OCIHandleFree((dvoid *)svchp, OCI_HTYPE_SVCCTX); OCIHandleFree((dvoid *)srvhp, OCI_HTYPE_SERVER); return 0; } ``` ## JDBC 驱动 OceanBase 数据库提供了基于 Java JDBC 标准的数据库驱动，JDBC（Java Database Connectivity）是 Java 应用程序访问数据库的标准 API（应用程序编程接口），数据库驱动的实现会将 JDBC 标准编程接口转换成对应数据库厂商的 SQL 实现。OceanBase 数据库 JDBC 驱动兼容 JDBC 4.0、4.1、4.2 标准。 JDBC 连接串的前置为 jdbc:oceanbase，其他使用和标准 JDBC 方式保持一致。样例代码： ```javascript String url = "jdbc:oceanbase://host:port/SYS?useUnicode=true&characterEncoding=utf-8"; String username = "SYS@oracle"; String password = ""; Connection conn = null; try { Class.forName("com.alipay.oceanbase.jdbc.Driver"); conn = DriverManager.getConnection(url, username, password); PreparedStatement ps = conn.prepareStatement("select to_char(sysdate,'yyyy-MM-dd HH24:mi:ss') from dual;"); ResultSet rs = ps.executeQuery(); rs.next(); System.out.println("sysdate is:" + rs.getString(1)); rs.close(); ps.close(); } catch (Exception e) { e.printStackTrace(); } finally { if (null != conn) { conn.close(); } } ``` ## ODBC 驱动 OceanBase 数据库提供了基于 ODBC 标准的数据库驱动，ODBC (Open Database Connectivity）和 JDBC 标准一样，提供了一种标准的 API（应用程序编程接口）方法来访问数据库管理系统，目前已经被业界广泛接受。 目前 OceanBase 数据库提供了 Linux 版本和 Windows 版本的 ODBC 驱动，样例代码： ```javascript #include #include #include #include "sql.h" #include "sqlext.h" #define MAX_NAME_LEN 255 typedef struct tagODBCHandler { SQLHENV henv; SQLHDBC hdbc; SQLHSTMT hstmt; }ODBCHandler; int IS_SUCC(SQLRETURN retcode) { if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) return 1; return 0; } int main(int argc, char** argv) { ODBCHandler handler; SQLRETURN retcode; SQLCHAR connOut[MAX_NAME_LEN+1]; SQLSMALLINT len; //Allocate environment handle retcode = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &handler.henv); // Set the ODBC version environment attribute if (!IS_SUCC(retcode)) { return -1; } retcode = SQLSetEnvAttr(handler.henv, SQL_ATTR_ODBC_VERSION, (SQLPOINTER)SQL_OV_ODBC3_80, 0); // Allocate connection handle if (!IS_SUCC(retcode)) { return -1; } retcode = SQLAllocHandle(SQL_HANDLE_DBC, handler.henv, &handler.hdbc); if (!IS_SUCC(retcode)) { return -1; } // Set login timeout to 5 seconds SQLSetConnectAttr(handler.hdbc, SQL_LOGIN_TIMEOUT, (SQLPOINTER)5, 0); // Connect to data source retcode = SQLDriverConnect(handler.hdbc, NULL, (SQLCHAR*)"DSN=odbctest", SQL_NTS, connOut, MAX_NAME_LEN, &len,SQL_DRIVER_NOPROMPT); if (!IS_SUCC(retcode)) { return -1; } retcode = SQLAllocHandle(SQL_HANDLE_STMT, handler.hdbc, &handler.hstmt); if (!IS_SUCC(retcode)) { return -1; } { //insert retcode = SQLPrepare(handler.hstmt, (SQLCHAR*)"insert into PERSON values(?,?,'test')", SQL_NTS); if (!IS_SUCC(retcode)) { return -1; } SQLINTEGER id = 0; SQLINTEGER num = 0; retcode = SQLBindParameter(handler.hstmt, 1, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER, 0, 0, &id, 0, NULL); if (!IS_SUCC(retcode)) { return -1; } retcode = SQLBindParameter(handler.hstmt, 2, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER, 0, 0, &num, 0, NULL); if (!IS_SUCC(retcode)) { return -1; } retcode = SQLExecute(handler.hstmt); if (!IS_SUCC(retcode)) { return -1; } } // clean handle SQLFreeHandle(SQL_HANDLE_STMT, handler.hstmt); SQLDisconnect(handler.hdbc); SQLFreeHandle(SQL_HANDLE_DBC, handler.hdbc); SQLFreeHandle(SQL_HANDLE_ENV, handler.henv); return 0; } ``` 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线