当前位置：首页 > 行业动态 > 正文

c 与sql数据库的连接

admin
行业动态
2025-02-19
10

要实现C语言与SQL数据库的连接，通常需要使用数据库提供的C语言接口库（如MySQL的libmysqlclient、PostgreSQL的libpq等），通过编写代码建立连接、执行SQL语句并处理结果。

C语言与SQL数据库的连接是实现数据持久化存储和高效管理的关键步骤，下面将详细介绍如何通过C语言连接到SQL数据库，包括使用ODBC（Open Database Connectivity）驱动、ADO（ActiveX Data Objects）以及第三方库等方法。

一、使用ODBC连接SQL Server

1、加载ODBC驱动：在使用ODBC连接SQL Server之前，需要确保已安装SQL Server的ODBC驱动程序，Windows系统通常自带SQL Server ODBC驱动，但可以根据需要下载和更新到最新版本。

2、初始化环境和分配句柄：在C语言中，通常使用SQLAllocHandle函数来初始化环境和分配句柄，以下是一个简单的示例代码：

   #include <stdio.h>
   #include <sql.h>
   #include <sqlext.h>
   SQLHENV hEnv;
   SQLHDBC hDbc;
   SQLHSTMT hStmt;
   int main() {
       SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &hEnv);
       SQLSetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
       SQLAllocHandle(SQL_HANDLE_DBC, hEnv, &hDbc);
       // 继续连接数据库
   }

3、建立数据库连接：使用SQLConnect函数来建立与SQL Server数据库的连接，需要提供数据源名称（DSN）、用户名和密码：

   SQLCHAR* dsn = (SQLCHAR*)"DataSourceName";
   SQLCHAR* user = (SQLCHAR*)"username";
   SQLCHAR* password = (SQLCHAR*)"password";
   SQLRETURN ret = SQLConnect(hDbc, dsn, SQL_NTS, user, SQL_NTS, password, SQL_NTS);
   if (ret == SQL_SUCCESS || ret == SQL_SUCCESS_WITH_INFO) {
       printf("Connected to SQL Server
");
   } else {
       printf("Connection failed
");
   }

4、执行SQL语句：成功连接到数据库后，可以使用SQLExecDirect函数执行SQL语句，查询一个表的数据：

   SQLAllocHandle(SQL_HANDLE_STMT, hDbc, &hStmt);
   SQLCHAR* sql = (SQLCHAR*)"SELECT * FROM my_table";
   ret = SQLExecDirect(hStmt, sql, SQL_NTS);
   if (ret == SQL_SUCCESS || ret == SQL_SUCCESS_WITH_INFO) {
       printf("Query executed successfully
");
   } else {
       printf("Query execution failed
");
   }

5、处理结果集：使用SQLFetch函数来获取查询结果，并使用SQLGetData函数来读取每一列的数据：

   SQLCHAR col1[256];
   SQLCHAR col2[256];
   while (SQLFetch(hStmt) == SQL_SUCCESS) {
       SQLGetData(hStmt, 1, SQL_C_CHAR, col1, sizeof(col1), NULL);
       SQLGetData(hStmt, 2, SQL_C_CHAR, col2, sizeof(col2), NULL);
       printf("Col1: %s, Col2: %s
", col1, col2);
   }

6、关闭连接和释放资源：在完成数据库操作后，需要关闭连接并释放分配的句柄：

c 与sql数据库的连接第1张

   SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
   SQLDisconnect(hDbc);
   SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
   SQLFreeHandle(SQL_HANDLE_ENV, hEnv);

二、使用ADO连接SQL Server

1、初始化COM库：在使用ADO之前，必须初始化COM库：

   #include <windows.h>
   #include <comdef.h>
   #include <msado15.tlb>
   int main() {
       CoInitialize(NULL);
       // 继续进行ADO操作
   }

2、创建Connection对象并建立连接：使用Connection对象的Open方法来建立与SQL Server的连接：

   ADODB::_ConnectionPtr pConn;
   HRESULT hr = pConn.CreateInstance(__uuidof(ADODB::Connection));
   pConn->Open("Provider=SQLOLEDB;Data Source=ServerName;Initial Catalog=DatabaseName;User ID=username;Password=password;", "", "", ADODB::adConnectUnspecified);

3、执行SQL语句：使用Command对象或Connection对象的Execute方法来执行SQL语句：

   ADODB::_RecordsetPtr pRst = pConn->Execute("SELECT * FROM my_table", NULL, ADODB::adCmdText);

4、处理结果集：遍历Recordset对象来处理查询结果：

   while (!pRst->adoEOF) {
       _bstr_t col1 = pRst->Fields->Item["col1"]->Value;
       _bstr_t col2 = pRst->Fields->Item["col2"]->Value;
       printf("Col1: %s, Col2: %s
", (const char*)col1, (const char*)col2);
       pRst->MoveNext();
   }

5、关闭连接和释放资源：完成操作后，关闭连接并释放资源：

   pRst->Close();
   pConn->Close();
   CoUninitialize();

三、使用第三方库连接SQL Server

1、安装第三方库：根据所选库的文档进行安装和配置，安装FreeTDS：

   sudo apt-get install freetds-dev

2、编写连接代码：使用第三方库的API进行连接和操作，以下是FreeTDS的示例代码：

   #include <sybfront.h>
   #include <sybdb.h>
   DBPROCESS* dbproc;
   LOGINREC* login;
   int main() {
       dbinit();
       login = dblogin();
       DBSETLUSER(login, "username");
       DBSETLPWD(login, "password");
       dbproc = dbopen(login, "ServerName");
       if (dbproc != NULL) {
           dbcmd(dbproc, "SELECT * FROM my_table");
           dbsqlexec(dbproc);
           dbresults(dbproc);
           while (dbnextrow(dbproc) != NO_MORE_ROWS) {
               printf("Col1: %s, Col2: %s
", dbdata(dbproc, 1), dbdata(dbproc, 2));
           }
           dbclose(dbproc);
       } else {
           printf("Connection failed
");
       }
       dbexit();
       return 0;
   }