C语言与sqlserver数据库

原文:C语言与sqlserver数据库

1.使用C语言来操作SQL SERVER数据库,采用ODBC开放式数据库连接进行数据的添加,修改,删除,查询等操作。
 step1:启动SQLSERVER服务,例如:HNHJ,开始菜单 ->运行 ->net start mssqlserver
 step2:打开企业管理器,建立数据库test,在test库中建立test表(a varchar(200),b varchar(200))
 step3:建立系统DSN,开始菜单 ->运行 ->odbcad32,
  添加->SQL SERVER
 名称：csql,服务器：HNHJ
 使用用户使用登录ID和密码的SQLSERVER验证,登录ID:sa,密码:
  更改默认的数据库为:test
 ...
 测试数据源，测试成功，即DNS添加成功。

2.cpp文件完整代码

//##########################save.cpp##########################

1. #include <stdio.h>
2. #include <string.h>
3. #include <windows.h>
4. #include <sql.h>
5. #include <sqlext.h>
6. #include <sqltypes.h>
7. #include <odbcss.h>
8. SQLHENV henv = SQL_NULL_HENV;
9. SQLHDBC hdbc1 = SQL_NULL_HDBC;
10. SQLHSTMT hstmt1 = SQL_NULL_HSTMT;
11. /*
12. cpp文件功能说明：
13. 1.数据库操作中的添加，修改，删除，主要体现在SQL语句上
14. 2.采用直接执行方式和参数预编译执行方式两种
15. */
16. int main(){
17. RETCODE retcode;
18. UCHAR   szDSN[SQL_MAX_DSN_LENGTH+1]   =   "csql",
19. szUID[MAXNAME]   =   "sa",
20. szAuthStr[MAXNAME]   =   "";
21. //SQL语句
22. //直接SQL语句
23. UCHAR   sql[37] = "insert into test values('aaa','100')";
24. //预编译SQL语句
25. UCHAR   pre_sql[29] = "insert into test values(?,?)";
26. //1.连接数据源
27. //1.环境句柄
28. retcode   =   SQLAllocHandle   (SQL_HANDLE_ENV,   NULL,   &henv);
29. retcode   =   SQLSetEnvAttr(henv,   SQL_ATTR_ODBC_VERSION,
30. (SQLPOINTER)SQL_OV_ODBC3,
31. SQL_IS_INTEGER);
32. //2.连接句柄
33. retcode   =   SQLAllocHandle(SQL_HANDLE_DBC,   henv,   &hdbc1);
34. retcode   =   SQLConnect(hdbc1,   szDSN,   4,   szUID,   2,   szAuthStr,   0);
35. //判断连接是否成功
36. if   (   (retcode   !=   SQL_SUCCESS)   &&   (retcode   !=   SQL_SUCCESS_WITH_INFO)   )   {
37. printf("连接失败!/n");
38. }   else   {
39. //2.创建并执行一条或多条SQL语句
40. /*
41. 1.分配一个语句句柄(statement handle)
42. 2.创建SQL语句
43. 3.执行语句
44. 4.销毁语句
45. */
46. retcode   =   SQLAllocHandle(SQL_HANDLE_STMT,   hdbc1,   &hstmt1);
47. //第一种方式
48. //直接执行
49. //添加操作
50. //SQLExecDirect (hstmt1,sql,37);
51. //第二种方式
52. //绑定参数方式
53. char a[200]="bbb";
54. char b[200]="200";
55. SQLINTEGER   p   =   SQL_NTS;
56. //1预编译
57. SQLPrepare(hstmt1,pre_sql,29); //第三个参数与数组大小相同，而不是数据库列相同
58. //2绑定参数值
59. SQLBindParameter(hstmt1,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&a,0,&p);
60. SQLBindParameter(hstmt1,2,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&b,0,&p);
61. //3 执行
62. SQLExecute(hstmt1);
63. printf("操作成功!");
64. //释放语句句柄
65. SQLCloseCursor (hstmt1);
66. SQLFreeHandle (SQL_HANDLE_STMT, hstmt1);
67. }
68. //3.断开数据源
69. /*
70. 1.断开与数据源的连接.
71. 2.释放连接句柄.
72. 3.释放环境句柄 (如果不再需要在这个环境中作更多连接)
73. */
74. SQLDisconnect(hdbc1);
75. SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);
76. SQLFreeHandle(SQL_HANDLE_ENV, henv);
77. return(0);
78. }

#include <stdio.h>
#include <string.h>
#include <windows.h>
#include <sql.h>
#include <sqlext.h>
#include <sqltypes.h>
#include <odbcss.h>   

SQLHENV henv = SQL_NULL_HENV;
SQLHDBC hdbc1 = SQL_NULL_HDBC;
SQLHSTMT hstmt1 = SQL_NULL_HSTMT;   

/*
	cpp文件功能说明：
	1.数据库操作中的添加，修改，删除，主要体现在SQL语句上
	2.采用直接执行方式和参数预编译执行方式两种
*/
int main(){
	RETCODE retcode;
	UCHAR	szDSN[SQL_MAX_DSN_LENGTH+1]   =   "csql",
            szUID[MAXNAME]   =   "sa",
            szAuthStr[MAXNAME]   =   "";
	//SQL语句
		//直接SQL语句
	UCHAR	sql[37] = "insert into test values('aaa','100')";
		//预编译SQL语句
	UCHAR	pre_sql[29] = "insert into test values(?,?)";
	//1.连接数据源
		//1.环境句柄
	retcode   =   SQLAllocHandle   (SQL_HANDLE_ENV,   NULL,   &henv);
	retcode   =   SQLSetEnvAttr(henv,   SQL_ATTR_ODBC_VERSION,
				  (SQLPOINTER)SQL_OV_ODBC3,
				  SQL_IS_INTEGER);
		//2.连接句柄
	retcode   =   SQLAllocHandle(SQL_HANDLE_DBC,   henv,   &hdbc1);
	retcode   =   SQLConnect(hdbc1,   szDSN,   4,   szUID,   2,   szAuthStr,   0);
	//判断连接是否成功
	if   (   (retcode   !=   SQL_SUCCESS)   &&   (retcode   !=   SQL_SUCCESS_WITH_INFO)   )   {
		printf("连接失败!/n");
	}   else   {
		//2.创建并执行一条或多条SQL语句
		/*
		1.分配一个语句句柄(statement handle)
		2.创建SQL语句
		3.执行语句
		4.销毁语句
		*/
		retcode   =   SQLAllocHandle(SQL_HANDLE_STMT,   hdbc1,   &hstmt1);
		//第一种方式
		//直接执行
		//添加操作
		//SQLExecDirect (hstmt1,sql,37);

		//第二种方式
		//绑定参数方式
		char a[200]="bbb";
		char b[200]="200";
		SQLINTEGER   p   =   SQL_NTS;
		//1预编译
		SQLPrepare(hstmt1,pre_sql,29); //第三个参数与数组大小相同，而不是数据库列相同
		//2绑定参数值
		SQLBindParameter(hstmt1,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&a,0,&p);
		SQLBindParameter(hstmt1,2,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&b,0,&p);
		//3 执行
		SQLExecute(hstmt1);

		printf("操作成功!");
		//释放语句句柄
		SQLCloseCursor (hstmt1);
		SQLFreeHandle (SQL_HANDLE_STMT, hstmt1);

	}
	//3.断开数据源
	/*
     1.断开与数据源的连接.
	 2.释放连接句柄.
	 3.释放环境句柄 (如果不再需要在这个环境中作更多连接)
    */
	SQLDisconnect(hdbc1);
	SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);
	SQLFreeHandle(SQL_HANDLE_ENV, henv);
	return(0);
}   

//##########################list.cpp##########################

1. #include <stdio.h>
2. #include <string.h>
3. #include <windows.h>
4. #include <sql.h>
5. #include <sqlext.h>
6. #include <sqltypes.h>
7. #include <odbcss.h>
8. SQLHENV henv = SQL_NULL_HENV;
9. SQLHDBC hdbc1 = SQL_NULL_HDBC;
10. SQLHSTMT hstmt1 = SQL_NULL_HSTMT;
11. /*
12. 查询SQLSERVER数据库,1.条件查询,2.直接查询全部
13. */
14. int main(){
15. RETCODE retcode;
16. UCHAR   szDSN[SQL_MAX_DSN_LENGTH+1]   =   "csql",
17. szUID[MAXNAME]   =   "sa",
18. szAuthStr[MAXNAME]   =   "";
19. UCHAR   sql1[39] = "select b from test where a = 'aaa'";
20. UCHAR   sql2[35] = "select b from test where a = ? ";
21. UCHAR   sql3[19] = "select b from test";
22. retcode   =   SQLAllocHandle   (SQL_HANDLE_ENV,   NULL,   &henv);
23. retcode   =   SQLSetEnvAttr(henv,   SQL_ATTR_ODBC_VERSION,
24. (SQLPOINTER)SQL_OV_ODBC3,
25. SQL_IS_INTEGER);
26. retcode   =   SQLAllocHandle(SQL_HANDLE_DBC,   henv,   &hdbc1);
27. //1.连接数据源
28. retcode   =   SQLConnect(hdbc1,   szDSN,   4,   szUID,   2,   szAuthStr,   0);
29. if   (   (retcode   !=   SQL_SUCCESS)   &&   (retcode   !=   SQL_SUCCESS_WITH_INFO)   )   {
30. printf("连接失败!");
31. }   else   {
32. //2.创建并执行一条或多条SQL语句
33. /*
34. 1.分配一个语句句柄(statement handle)
35. 2.创建SQL语句
36. 3.执行语句
37. 4.销毁语句
38. */
39. retcode   =   SQLAllocHandle(SQL_HANDLE_STMT,   hdbc1,   &hstmt1);
40. //第一种方式
41. /*
42. //直接执行
43. SQLExecDirect (hstmt1,sql1,39);
44. char list[5];
45. SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
46. SQLFetch(hstmt1);
47. printf("%s/n",list);
48. */
49. //第二种方式
50. /*
51. //绑定参数方式
52. char a[200]="aaa";
53. SQLINTEGER   p   =   SQL_NTS;
54. //1.预编译
55. SQLPrepare(hstmt1,sql2,35); //第三个参数与数组大小相同，而不是数据库列相同
56. //2.绑定参数值
57. SQLBindParameter(hstmt1,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&a,0,&p);
58. //3.执行
59. SQLExecute(hstmt1);
60. char list[5];
61. SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
62. SQLFetch(hstmt1);
63. printf("%s/n",list);
64. */
65. //第三种方式全部输出
66. /*
67. 1.确认一个结果集是否可用。
68. 2.将结果集的列绑定在适当的变量上。
69. 3.取得行
70. */
71. //3.检查结果记录(如果有的话)
72. SQLExecDirect (hstmt1,sql3,19);
73. char list[5];
74. SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
75. do{
76. retcode = SQLFetch(hstmt1);
77. if(retcode == SQL_NO_DATA){
78. break;
79. }
80. printf("%s/n",list);
81. }while(1);
82. //释放语句句柄
83. SQLCloseCursor (hstmt1);
84. SQLFreeHandle (SQL_HANDLE_STMT, hstmt1);
85. }
86. //4.断开数据源
87. /*
88. 1.断开与数据源的连接.
89. 2.释放连接句柄.
90. 3.释放环境句柄 (如果不再需要在这个环境中作更多连接)
91. */
92. SQLDisconnect(hdbc1);
93. SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);
94. SQLFreeHandle(SQL_HANDLE_ENV, henv);
95. return(0);
96. }

#include <stdio.h>
#include <string.h>
#include <windows.h>
#include <sql.h>
#include <sqlext.h>
#include <sqltypes.h>
#include <odbcss.h>   

SQLHENV henv = SQL_NULL_HENV;
SQLHDBC hdbc1 = SQL_NULL_HDBC;
SQLHSTMT hstmt1 = SQL_NULL_HSTMT;   

/*
	查询SQLSERVER数据库,1.条件查询,2.直接查询全部
*/
int main(){
	RETCODE retcode;
	UCHAR   szDSN[SQL_MAX_DSN_LENGTH+1]   =   "csql",
            szUID[MAXNAME]   =   "sa",
            szAuthStr[MAXNAME]   =   "";
    UCHAR	sql1[39] = "select b from test where a = 'aaa'";
	UCHAR	sql2[35] = "select b from test where a = ? ";
	UCHAR	sql3[19] = "select b from test";

	retcode   =   SQLAllocHandle   (SQL_HANDLE_ENV,   NULL,   &henv);
	retcode   =   SQLSetEnvAttr(henv,   SQL_ATTR_ODBC_VERSION,
				  (SQLPOINTER)SQL_OV_ODBC3,
				  SQL_IS_INTEGER);
	retcode   =   SQLAllocHandle(SQL_HANDLE_DBC,   henv,   &hdbc1);
	//1.连接数据源
	retcode   =   SQLConnect(hdbc1,   szDSN,   4,   szUID,   2,   szAuthStr,   0);
	if   (   (retcode   !=   SQL_SUCCESS)   &&   (retcode   !=   SQL_SUCCESS_WITH_INFO)   )   {
		printf("连接失败!");
	}   else   {
		//2.创建并执行一条或多条SQL语句
		/*
		1.分配一个语句句柄(statement handle)
		2.创建SQL语句
		3.执行语句
		4.销毁语句
		*/
		retcode   =   SQLAllocHandle(SQL_HANDLE_STMT,   hdbc1,   &hstmt1);
		//第一种方式
		/*
		//直接执行
		SQLExecDirect (hstmt1,sql1,39);
		char list[5];
		SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
		SQLFetch(hstmt1);
		printf("%s/n",list);
		*/

		//第二种方式
		/*
		//绑定参数方式
		char a[200]="aaa";
		SQLINTEGER   p   =   SQL_NTS;
		//1.预编译
		SQLPrepare(hstmt1,sql2,35); //第三个参数与数组大小相同，而不是数据库列相同
		//2.绑定参数值
		SQLBindParameter(hstmt1,1,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,200,0,&a,0,&p);
		//3.执行
		SQLExecute(hstmt1);
		char list[5];
		SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
		SQLFetch(hstmt1);
		printf("%s/n",list);
		*/

		//第三种方式全部输出
		/*
		1.确认一个结果集是否可用。
		2.将结果集的列绑定在适当的变量上。
		3.取得行
		*/
		//3.检查结果记录(如果有的话)
		SQLExecDirect (hstmt1,sql3,19);
		char list[5];
		SQLBindCol(hstmt1, 1, SQL_C_CHAR, list, 5, 0);
		do{
			retcode = SQLFetch(hstmt1);
			if(retcode == SQL_NO_DATA){
				break;
			}
			printf("%s/n",list);
		}while(1);

		//释放语句句柄
		SQLCloseCursor (hstmt1);
		SQLFreeHandle (SQL_HANDLE_STMT, hstmt1);

	}   

	//4.断开数据源
	/*
     1.断开与数据源的连接.
	 2.释放连接句柄.
	 3.释放环境句柄 (如果不再需要在这个环境中作更多连接)
    */
	SQLDisconnect(hdbc1);
	SQLFreeHandle(SQL_HANDLE_DBC, hdbc1);
	SQLFreeHandle(SQL_HANDLE_ENV, henv);
	return(0);
}  

3.总结：ODBC数据库操作与JDBC步骤上类似，可以融汇贯通来学习

本文来自于http://simpledev.javaeye.com/blog/339537