SQLServer学习(7)C语言txt文本插入数据库

2019-06-07#SQL Server #C

之前我的一些有关于SQLServer学习的文章：

SQL Server学习(1)介绍与安装

SQL Server学习(2)创建数据库和数据表

SQLServer学习(3)导入导出数据表

SQLServer学习(4)给数据库、表生成SQL脚本

SQLServer学习(5)为SQLServer创建登录账户

SQLServer学习(6)C语言连接数据库

我的配置：

操作系统：Window10 x64
SQL Server 2016
IDE：Visual Studio 2017

这篇文章将介绍如何用C语言将TXT文本数据插入SQLServer数据库。

读取TXT文件内容

首先，抛开SQLServer数据库，单纯地用C语言实现读取TXT格式文本内容。

代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define MAX_LINE 1024
struct data {
	int id;
	char name[10];
}person[1000];

int main()
{
	char buf[MAX_LINE];  /*缓冲区*/
	FILE *fp;            /*文件指针*/
	int len;             /*行字符个数*/
	int i=0;
	if ((fp = fopen("D:\\vs_project\\WriteTXT\\WriteTXT\\WriteTXT\\test.txt", "r")) == NULL)
	{ //如果打开文件错误，报错，退出
		perror("fail to read"); 
		exit(1);
	}
	printf("id\tname\n");
	while(fgets(buf, MAX_LINE, fp) != NULL)
	{
		len = strlen(buf);
		buf[len - 1] = '\0';  /*去掉换行符*/
		
		sscanf(buf,"%d,%s", &person[i].id, &person[i].name);
		printf("%d\t%s\n", person[i].id, person[i].name);
		i++;	
	}
	printf("num:%d\n", i);
	getchar(); 
	//关闭文件 
	fclose(fp);
	return 0;
}

报错

VS使用fopen()时可能会报如图错误“error C4996: ‘fopen’: This function or variable may be unsafe. Consider using fopen_s instead. To disable deprecation, use _CRT_SECURE_NO_WARNINGS. See online help for details.”：

解决方法

（1）在VS中，在“解决方案资源管理器”中项目名上单击右键——选择“属性”。

（2）在属性页中的“预处理器”中添加预处理定义。

（3）把 _CRT_SECURE_NO_WARNINGS添加进去，确定保存即可，再次运行就没有问题了。

结果

TXT文本文件里的内容，如图：

程序运行效果如图：

插入数据库

结合上一篇文章SQLServer学习(6)C语言连接数据库将部分代码修改写成void insertData(int i)函数，然后和上文读取TXT文本的代码写成int readTxt(char path[1024])函数相结合即可。

代码

#include <stdio.h>
#include <string.h>     
#include <windows.h>     
#include <sql.h>     
#include <sqlext.h>     
#include <sqltypes.h>     
#include <odbcss.h>  
#include <stdlib.h>
#define MAX_LINE 1024

SQLINTEGER id;
SQLCHAR name[20];
SQLINTEGER len_id, len_name;

struct data {
	int id;
	char name[10];
}person[1000];

/*读取txt文件*/
int readTxt(char path[1024])
{
	char buf[MAX_LINE];  //缓冲区
	FILE *fp;            //文件指针
	int len;             //行字符个数
	int i = 0;
	if ((fp = fopen(path, "r")) == NULL)
	{
		perror("fail to read");
		exit(1);
	}
	printf("id\tname\n");
	while (fgets(buf, MAX_LINE, fp) != NULL)
	{
		len = strlen(buf);
		buf[len - 1] = '\0';  //去掉换行符
		sscanf(buf, "%d,%s", &person[i].id, &person[i].name);
		printf("%d\t%s\n", person[i].id, person[i].name);
		i++;
	}
	printf("num:%d\n", i);
	//关闭文件 
	fclose(fp);
	return i;
}
/*插入数据*/
void insertData(int i) {
	SQLRETURN retcode;
	SQLHENV henv;
	SQLHDBC hdbc;
	SQLHSTMT hstmt;

	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, &hdbc); //申请数据库连接句柄
	retcode = SQLConnect(hdbc, (SQLCHAR*)"SQLC", SQL_NTS, (SQLCHAR*)"SQLC", SQL_NTS, (SQLCHAR*)"SQLC123", SQL_NTS);
	if ((retcode == SQL_SUCCESS) || (retcode == SQL_SUCCESS_WITH_INFO)) { //判断是否成功执行
		printf("insertDataBase success!\n");
		retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc, &hstmt);//申请SQL语句句柄 
		SQLCHAR sql[] = "USE test2";
		retcode = SQLExecDirect(hstmt, sql, SQL_NTS);//直接执行SQL语句
		SQLCHAR sql1[] = "INSERT INTO test VALUES (?,?);";
		SQLINTEGER P = SQL_NTS;
		retcode = SQLPrepare(hstmt, sql1, SQL_NTS);
		retcode = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT, SQL_C_LONG, SQL_INTEGER, 10, 0, &person[i].id, 0, &P);
		retcode = SQLBindParameter(hstmt, 2, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, 20, 0, &person[i].name, 20, &P);
		retcode = SQLExecute(hstmt);//执行插入SQL语句，前面可以用结构体加入问号内容
		if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO) {
			printf("insertData%d success!\n",i);
		}
		else {
			printf("insertData wrong!\n");
			SQLDisconnect(hdbc);//断开与数据库的连接 
		}

	}
	else {
		printf("insertDatabase wrong!\n");
		SQLDisconnect(hdbc);//断开与数据库的连接 
	}
	SQLFreeHandle(SQL_HANDLE_DBC, hdbc);//释放连接句柄 
	SQLFreeHandle(SQL_HANDLE_ENV, henv);//释放环境句柄
}
int main() {
	int num;
	int i;
	char path[]="D:\\vs_project\\WriteTXT\\WriteTXT\\WriteTXT\\test.txt";
	num = readTxt(path);
	for (i = 0; i < num; i++) {
		insertData(i);
	}
	getchar();
	return 0;
}