C语言轻松调用数据库数据 (c 中调用数据库中的数据)

随着云计算和大数据时代的到来，数据的处理变得越来越重要。现在，几乎所有的应用程序都需要与数据库进行交互，而应用程序开发人员也需要学会如何轻松调用数据库数据。

C语言是一种强大的编程语言，它被广泛用于系统级应用程序的开发。C语言也可以用于数据库编程，通过使用一些库和API，C语言开发人员可以轻松地连接数据库、查询数据、插入数据和更新数据。

一些常用的数据库引擎，比如MySQL和PostgreSQL，都提供了适用于C语言的API，这些API可以让C语言开发人员直接调用数据库。在本文中，我们将使用MySQL数据库举例来说明如何在C语言中调用数据库数据。

连接MySQL数据库

在使用C语言调用MySQL数据库之前，我们需要先建立与MySQL数据库的连接，这可以通过SQLConnect()函数来实现。SQLConnect()函数的之一个参数是一个指向ODBC连接的句柄，第二个参数是连接的DSN（数据源名称），第三个参数是用户名，第四个参数是密码。

以下是一个示例代码段，演示如何通过C语言连接MySQL数据库：

“`c

#include

#include

#include

int mn(int argc, char *argv[]) {

SQLHENV henv;

SQLHDBC hdbc;

SQLRETURN ret;

SQLCHAR outstr[1024];

SQLALLINT outstrlen;

// Allocate environment handle

ret = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv);

// Set the ODBC version number

ret = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);

// Allocate connection handle

ret = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc);

// Connect to the data source

ret = SQLConnect(hdbc, (SQLCHAR*)”datasource”, SQL_NTS, (SQLCHAR*)”username”, SQL_NTS, (SQLCHAR*)”password”, SQL_NTS);

// Allocate statement handle

SQLHSTMT hstmt;

ret = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);

// Do something with the database

// Clean up

SQLFreeHandle(SQL_HANDLE_STMT, hstmt);

SQLDisconnect(hdbc);

SQLFreeHandle(SQL_HANDLE_DBC, hdbc);

SQLFreeHandle(SQL_HANDLE_ENV, henv);

return 0;

}

“`

在上面的代码中，我们首先分配了一个ODBC环境句柄，然后设置了ODBC版本号，并分配了一个ODBC连接句柄。接着，我们使用SQLConnect()函数连接到MySQL数据库，然后分配一个ODBC语句句柄。

查询数据

在连接到MySQL数据库之后，我们可以使用SQLExecDirect()函数来执行SQL语句并查询数据。这个函数的之一个参数是ODBC语句句柄，第二个参数是一个指向包含要执行的SQL语句的字符串的指针，第三个参数是包含SQL语句长度的整数。

以下代码段演示了如何查询MySQL数据库中的数据：

“`c

SQLCHAR* query = “SELECT * FROM employees”;

SQLLEN queryLen = strlen(query);

// Execute the query

SQLRETURN ret = SQLExecDirect(hstmt, query, queryLen);

// Process the results

SQLCHAR name[512];

SQLLEN nameLen;

SQLINTEGER age;

SQLLEN ageLen;

while (SQLFetch(hstmt) == SQL_SUCCESS) {

SQLGetData(hstmt, 1, SQL_C_CHAR, name, 512, &nameLen);

SQLGetData(hstmt, 2, SQL_C_LONG, &age, sizeof(age), &ageLen);

printf(“%s, %d”, name, age);

}

“`

在上面的代码中，我们首先定义了一个指向SQL语句的指针，并使用strlen()函数获取了SQL语句的长度。然后，我们使用SQLExecDirect()函数执行SQL语句，并使用SQLFetch()函数逐行取回数据。

我们使用SQLGetData()函数将数据存储到C语言变量中，并打印出来。

插入数据

除了查询数据之外，我们还可以通过C语言向MySQL数据库中插入数据。这可以使用SQLBindParameter()函数来绑定SQL语句中的参数，并使用SQLExecute()函数执行SQL语句。

以下代码段演示了如何向MySQL数据库插入数据：

“`c

SQLCHAR* query = “INSERT INTO employees (name, age) VALUES (?, ?)”;

SQLLEN queryLen = strlen(query);

SQLINTEGER age = 30;

SQLLEN ageLen = sizeof(age);

SQLCHAR name[512] = “John Smith”;

SQLLEN nameLen = strlen(name);

// Prepare the statement

SQLPrepare(hstmt, query, queryLen);

// Bind the parameters

SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 512, 0, name, nameLen, &nameLen);

SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER, 0, 0, &age, sizeof(age), &ageLen);

// Execute the query

SQLRETURN ret = SQLExecute(hstmt);

“`

在上面的代码中，我们首先定义了一个指向SQL语句的指针，并使用strlen()函数获取了SQL语句的长度。然后，我们使用SQLPrepare()函数准备SQL语句，使用SQLBindParameter()函数绑定SQL语句中的参数，并使用SQLExecute()函数执行SQL语句。

更新数据

我们可以使用C语言更新MySQL数据库中的数据。这可以使用SQLExecDirect()函数来执行SQL UPDATE语句，并使用SQLRowCount()函数获取影响的行数。

以下代码段演示了如何更新MySQL数据库中的数据：

“`c

SQLCHAR* query = “UPDATE employees SET age = 35 WHERE name = ‘John Smith’”;

SQLLEN queryLen = strlen(query);

// Execute the query

SQLRETURN ret = SQLExecDirect(hstmt, query, queryLen);

// Get the number of rows affected

SQLLEN rowCount;

SQLRowCount(hstmt, &rowCount);

printf(“%d rows updated”, rowCount);

“`

在上面的代码中，我们定义了一个指向SQL语句的指针，并使用strlen()函数获取了SQL语句的长度。然后，我们使用SQLExecDirect()函数执行SQL UPDATE语句，并使用SQLRowCount()函数获取影响的行数。

结论

相关问题拓展阅读：

• 用C语言怎么实现与数据库的连接
• 请问如何用C或C++把mysql数据库中的某一列数据读出来，然后把这一列数据存放在数组中？急用！！！谢谢！

用C语言怎么实现与数据库的连接

可以去看一下 ado 或者 odbc

#include

#include

intmain()

{

MYSQL*conn;

MYSQL_RES*res;

MYSQL_ROWrow;

char*server=”localhost”;//本地连接

char*user=”root”;//

char*password=””;//mysql密码

char*database=”student”;//数据库名

char*query=”select*fromclass”中拦;//需要查询的语句

intt,r;

conn=mysql_init(NULL);

if(!mysql_real_connect(conn,server,user,password,database,0,NULL,0))

{

printf(“Errorconnectingtodatabase:%s\n”,mysql_error(conn));

}else{

printf(“Connected…\n”);

}

t=mysql_query(conn,query);

if(t)

{

printf(“Errormakingquery:%s\n”,mysql_error(conn));

}else{

printf(“Querymade…\n”);

res=mysql_use_result(conn);

if(res)

{

while((row=mysql_fetch_row(res))!=NULL)

{

//printf(“num=%d\n”,mysql_num_fields(res));//列数

for(t=0;t   

#include  

#include  

void   main()   

{ 

    HENV   henv;  //环境句柄 

    HDBC   hdbc;  //数州银据源句柄 

    HSTMT   hstmt;  //执行语句句柄 

    unsigned   char   datasource=”数据源名称”;  //即ODBC源中设置的源名称 

    unsigned   char   user= “用户名”;  //数据库的帐户名 

    unsigned   char   pwd= “密码”;  //数据库的密码 

    unsigned   char   search=”select   xm   from   stu   where   xh=0″;  

    SQLRETURN   retcode; //记录各SQL函数的返回情况 

    // 分配环境句柄 

    retcode= SQLAllocEnv(&henv);  // 等介于 SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv); 

    // 设置ODBC环境版本号为3.0 

    retcode= SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0); 

    // 分配连接句柄 

    retcode= SQLAllocConnect(henv,&hdbc); // 等介于 SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc); 

    //设置连接属性,登录超时为*rgbValue秒（可以没有）

     // SQLSetConnectAttr(hdbc, SQL_LOGIN_TIMEOUT, (SQLPOINTER)(rgbValue), 0);

    //直接连接数据源 

    // 如果是windows身份验证，第二、三参数可以是NULL，也可以是任何字串 

    //SQL_NTS 即 “Null-Terminated   String”  

    retcode= SQLConnect(hdbc,datasource, SQL_NTS, user, SQL_NTS , pwd, SQL_NTS );  

    //分配语句句柄 

    retcode= SQLAllocStmt(hdbc,&hstmt);  // 等介于 SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt); 

    //直接执行查询语句

    retcode=SQLExecDirect(hstmt,search,SQL_NTS);  

    //将数族扮据缓冲区绑定数据库中的相应字段（i是查询结果集列号，queryData是绑定缓冲区，BUFF_LENGTH是缓冲区长度） 

    SQLBindCol(hstmt, i, SQL_C_CHAR, queryData, BUFF_LENGTH, 0); 

    //遍历结果集到相应缓冲区 queryData

    SQLFetch(hstmt);   

    /* 

     *对遍历结果的相关操作，如显示等

     */ 

    //注意释放顺序，否则会造成未知错误！ 

    SQLFreeHandle(SQL_HANDLE_STMT, hstmt);

    SQLDisconnect(hdbc);

    SQLFreeHandle(SQL_HANDLE_DBC, hdbc);

    SQLFreeHandle(SQL_HANDLE_ENV, henv);

  }

代码看上去很复杂，其实都可以直接复制。其中需要改的是册穗宴数据源名称、数据库用户名、数据库密码和SQL语句。

然后就是SQLFetch后得到结果集后，如何使用的问题了。

在下面的注释部分 填写你的处理代码即可。

    /*

     *对遍历结果的相关操作，如显示等

     */

　　举个例子，连接SQL：

　　// 打缓悄凳开数据库运铅

　　strDBClass.Format(_T(“Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s;Jet OLEDB:Database Password=%s”), m_strUnEntryptMdbFilePath,m_strMDBPassword);

　　// 创建连接

　　HRESULT hr = m_pConnection.CreateInstance(_uuidof(Connection));

　　_ConnectionPtr m_pConnection->Open(m_strDBClass,_T(“”),_T(“”),adConnectUnspecified);

　　// 声明表单指针

　　_RecordsetPtrpBandRecordset;

　　pBandRecordset.CreateInstance(__uuidof(Recordset));

　　// 执行语句

　　CString strSQL（L”SELECT * FROM “）;

　　扰旅m_pConnection->Execute((LPCTSTR)strSQL,NULL,0);

　　// 提取某一项 例如BandInfo

　　int iBandInfo = wcscmp(colum, L”BandInfo”);

　　while(!recordsetPtr->adoEOF)

　　{

　　var = recordsetPtr->GetCollect(colum);

　　if(var.vt != VT_NULL)

　　strName = (LPCSTR)_bstr_t(var);

　　recordsetPtr->MoveNext();

请问如何用C或C++把mysql数据库中的某一列数据读出来，然后把这一列数据存放在数组中？急用！！！谢谢！

MYSQL_ROW row; 是mysql内部的类型盯塌，可能是一个结构体A，mysql先执行以下desc table的操作，依照表结构创建字段，也可能只是得到一行数据有清则液几列，分别是什么类型。

row = mysql_fetch_row(result)会取一样的数据，mysql里面每成功调用一次这个函数mysql_fetch_row就会取一行，类似

vector v_a;

··········赋值v_a·········

全局定义 int x = 0;

function: mysql_fetch_row

while (x

row = v_a;

mysql_fetch_lengths是得到一个row里面有多少数据，答物也就是table里的字段数

后面取的过程就很简单了，某个字段row 为空的时候，不做row ? row : “NULL” 取到的会是个’\0’，这个对于程序处理是比较危险的，为空的时候就附值一个标识是比较常用的做法。