unixODBC编程（四）插入数据
ODBC插入数据也有一定的步骤，我们先来看一下。
1. 分配一个语句句柄，使用SQLAllocHandle()函数，句柄类型为SQL_HANDLE_STMT。
2. 准备语句，使用SQLPrepare()函数。
3. 为绑定的变量赋值。
4. 绑定输入变量，使用SQLBindParameter()函数。
5. 执行语句，使用SQLExecute()函数。
6. 提交执行结果，使用SQLEndTran()函数。
这里只有两个新函数，SQLBindParameter()和SQLEndTran()。看一下他们的原型和参数。
绑定输入变量函数。
SQLRETURN SQLBindParameter(
SQLHSTMT StatementHandle,
SQLUSMALLINT ParameterNumber,
SQLSMALLINT InputOutputType,
SQLSMALLINT ValueType,
SQLSMALLINT ParameterType,
SQLULEN ColumnSize,
SQLSMALLINT DecimalDigits,
SQLPOINTER ParameterValuePtr,
SQLLEN BufferLength,
SQLLEN * StrLen_or_IndPtr);
StatementHandle是一个输入参数，语句句柄。
ParameterNumber是一个输入参数，参数编号，按递增参数顺序按顺序排序，从 1 开始。
InputOutputType是一个输入参数，指示绑定的参数是输入还是输出，这里是SQL_PARAM_INPUT。
ValueType是一个输入参数，指示绑定参数的 C 数据类型。参考下面的表。
ParameterType是一个输入参数，指示绑定参数的 SQL 数据类型。参考下面的表。
ColumnSize是一个输入参数，指示绑定参数列大小，即表的列长度。字符类型的列可以设置长度，其他类型会忽略。
DecimalDigits是一个输入参数，指示绑定参数标记的列的十进制数字位数。其他类型忽略。
ParameterValuePtr是一个输入参数，指向绑定参数数据的缓冲区的指针。
BufferLength是一个输入/输出参数，指示ParameterValuePtr 缓冲区的长度（以字节为单位）。主要限制输出的数据不要超出缓冲区。
StrLen_or_IndPtr是一个输入参数，指向绑定参数长度缓冲区的指针，用作输入的数据长度或指示变量。
ValueType类型对照表
| C 类型标识符 | ODBC C typedef | C 类型 |
|---|---|---|
| SQL_C_CHAR | SQLCHAR * | unsigned char * |
| SQL_C_WCHAR | SQLWCHAR * | wchar_t * |
| SQL_C_SSHORT | SQLSMALLINT | short int |
| SQL_C_USHORT | SQLUSMALLINT | unsigned short int |
| SQL_C_SLONG | SQLINTEGER | long int |
| SQL_C_ULONG | SQLUINTEGER | unsigned long int |
| SQL_C_FLOAT | SQLREAL | FLOAT |
| SQL_C_DOUBLE | SQLDOUBLE、SQLFLOAT | Double |
| SQL_C_BIT | SQLCHAR | unsigned char |
| SQL_C_STINYINT | SQLSCHAR | signed char |
| SQL_C_UTINYINT[j] | SQLCHAR | unsigned char |
| SQL_C_SBIGINT | SQLBIGINT | _int64 |
| SQL_C_UBIGINT | SQLUBIGINT | unsigned _int64 |
| SQL_C_BINARY | SQLCHAR * | unsigned char * |
事务提交函数。
SQLRETURN SQLEndTran(
SQLSMALLINT HandleType,
SQLHANDLE Handle,
SQLSMALLINT CompletionType);
HandleType是一个输入参数，句柄类型标识符。 包含SQL_HANDLE_ENV（如果 Handle 是环境句柄 ）或SQL_HANDLE_DBC（如果 Handle 是连接句柄）。
Handle是一个输入参数，HandleType 指示的类型句柄，指示事务的范围。
CompletionType是一个输入参数，以下两个值之一：SQL_COMMIT或SQL_ROLLBACK。
看一个实际的例子，在表中插入一条数据，表结构为：
Name Null? Type
----------------------------------------- -------- ----------------------------
ID NOT NULL NUMBER
F1 VARCHAR2(100)
F2 VARCHAR2(200)
F3 VARCHAR2(200)
F4 VARCHAR2(200)
插入语句为insert into test_tab1 (id, f1, f2, f3, f4) values (?, ?, ?, ?, ?)，问号表示输入参数，需要在后面绑定变量。实际的代码如下。
#include "stdio.h"
#include "stdlib.h"
#include "string.h"
#include "sql.h"
#include "sqlext.h"
#include "sqltypes.h"
SQLHANDLE envh; /* env handle */
SQLHANDLE dbch; /* connect handle */
SQLHANDLE stmth; /* statement handle */
int main(int argc, char *argv[])
{
int conn = 0;
SQLRETURN rc;
SQLLEN ind1;
SQLLEN ind2;
SQLLEN ind3;
SQLLEN ind4;
SQLLEN ind5;
SQLINTEGER id;
char dsn_str[32];
char usrname[32];
char passwd[32];
char sqltxt[512];
char f1[32];
char f2[32];
char f3[32];
char f4[32];
if (argc < 3) {
fprintf(stderr, "usage: %s dsn username password\n", argv[0]);
return (-1);
}
strncpy(dsn_str, argv[1], 32);
dsn_str[31] = '\0';
strncpy(usrname, argv[2], 32);
usrname[31] = '\0';
strncpy(passwd, argv[3], 32);
passwd[31] = '\0';
rc = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &envh);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Allocate environment handle error.\n");
return (-1);
}
rc = SQLSetEnvAttr(envh, SQL_ATTR_ODBC_VERSION, (void *)SQL_OV_ODBC3, 0);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Set ODBC version error.\n");
goto free_exit;
}
rc = SQLAllocHandle(SQL_HANDLE_DBC, envh, &dbch);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Allocate DB connection handle error.\n");
goto free_exit;
}
rc = SQLSetConnectAttr(dbch, SQL_ATTR_LOGIN_TIMEOUT, (SQLPOINTER)10, 0);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Set connection timeout value error.\n");
goto free_exit;
}
rc = SQLConnect(dbch, (SQLCHAR *)dsn_str, SQL_NTS, (SQLCHAR *)usrname, SQL_NTS, (SQLCHAR *)passwd, SQL_NTS);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Connect to DB error.\n");
goto free_exit;
}
conn = 1;
fprintf(stdout, "connect DB ok ......\n");
rc = SQLAllocHandle(SQL_HANDLE_STMT, dbch, &stmth);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Allocate statment handle error.\n");
goto free_exit;
}
sprintf(sqltxt, "insert into test_tab1 (id, f1, f2, f3, f4) values (?, ?, ?, ?, ?)");
rc = SQLPrepare(stmth, (SQLCHAR *)sqltxt, SQL_NTS);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Prepare statment error.\n");
goto free_exit;
}
id = 10;
strcpy(f1, "AAAAAAAAAA");
strcpy(f2, "BBBBBBBBBBBB");
strcpy(f3, "CCCCCCCCCCCCCC");
strcpy(f4, "DDDDDDDDDDDDDDDD");
ind1 = 0;
ind2 = SQL_NTS;
ind3 = SQL_NTS;
ind4 = SQL_NTS;
ind5 = SQL_NTS;
rc = SQLBindParameter(stmth, 1, SQL_PARAM_INPUT, SQL_C_SLONG, SQL_INTEGER, 0, 0, &id, 0, &ind1);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Bind column 1 error.\n");
goto free_exit;
}
rc = SQLBindParameter(stmth, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 100, 0, &f1, 0, &ind2);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Bind column 2 error.\n");
goto free_exit;
}
rc = SQLBindParameter(stmth, 3, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 200, 0, &f2, 0, &ind3);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Bind column 3 error.\n");
goto free_exit;
}
rc = SQLBindParameter(stmth, 4, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 200, 0, &f3, 0, &ind4);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Bind column 4 error.\n");
goto free_exit;
}
rc = SQLBindParameter(stmth, 5, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 200, 0, &f4, 0, &ind5);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Bind column 5 error.\n");
goto free_exit;
}
rc = SQLExecute(stmth);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "Execute statment error.\n");
goto free_exit;
}
rc = SQLEndTran(SQL_HANDLE_DBC, dbch, SQL_COMMIT);
if (rc != SQL_SUCCESS) {
fprintf(stderr, "End Transaction error.\n");
goto free_exit;
}
fprintf(stdout, "Insert data successed ......\n");
SQLFreeHandle(SQL_HANDLE_STMT, stmth);
SQLDisconnect(dbch);
SQLFreeHandle(SQL_HANDLE_DBC, dbch);
SQLFreeHandle(SQL_HANDLE_ENV, envh);
return (0);
free_exit:
if (stmth != NULL) {
SQLFreeHandle(SQL_HANDLE_STMT, stmth);
}
if (conn) {
SQLDisconnect(dbch);
}
if (dbch != NULL) {
SQLFreeHandle(SQL_HANDLE_DBC, dbch);
}
if (envh != NULL) {
SQLFreeHandle(SQL_HANDLE_ENV, envh);
}
return (-1);
}
如果对编程有兴趣，请访问www.tomcoding.com网站，里面有高技术含量的代码和文档下载。
原文地址：https://blog.csdn.net/tomcoding/article/details/142535979
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！