微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

c语言从文件中读入格式化数据并存入sqlite3

分类：Sqlite作者：编程之家
这周做数据库作业，其中一个小部分是从文件中读入格式化数据并存入sqlite3中。一开始只是为了完成实验内容而写了一个专门的函数来完成。
但写完之后发现有时候我们确实是需要从文件中读入格式化数据的。所以想写一个通用的函数，通过给定的参数来从文件中读入数据。

先是各个函数的解读，然后是所有的代码。
//************************************
// Method: insertData 从文件中读取记录并插入数据库
// FullName: insertData
// Access: public 
// Returns: int
// Qualifier:
// Parameter: sqlite3 * db sqlite3实例指针
// Parameter: char * fileName 要读取内容的文件名
// Parameter: int maxSize 每行记录的最大长度
// Parameter: char * tableName 要插入数据的表名
// Parameter: int length 字段数
// Parameter: int * format 每个字段的格式，数字:1，字符(串):0
//************************************
int insertData(sqlite3 *db,char *fileName,int maxSize,char *tableName,int length,int *format);
这个函数就是封装的读取插入数据的最终形态。参数简要描述如注释里面说的那样。前4个参数应该都好理解，可能需要解释的就是最后两个参数了。
int length 指的是你要插入数据的表(tableName)里一共有多少字段。
int *format 这其实是一个整型数组。你在定义的时候可以使用format[n]的形式，实参就是format。这个数组代表的是数据库表中每一个字段是数字还是字符串。了解数据库的同学应该都知道，简单的DBMS的sql语句在插入数值时其实只有三种:数字，字符串，NULL。而数字和NULL的插入方式是一样的。
如下是插入数字的sql语句:
insert into tableName (number)values(12);
这句话想tableName中插入了一组记录，插入的类型是数字。
如下是插入字符串的sql语句:
insert into talbeName (string) values ('hello world');
应该看出区别的了，两者的唯一区别就是字符串多了一对单(双)引号。因为在c语言中，字符串只能用双引号("")来括起来，所以我们在c语言里的sql语句只能使用单引号('')了。
那么上面的format就好理解了。按照顺序，如果第i个字段(从0计数)为字符串形式，则format[i] = 0,如果第i个字段为数字形势，则format[i] = 1;
当然，这个函数时假设插入的数据中是按顺序包含每一个字段。
如果需要只插入某些，可以自行修改。
//************************************
// Method: myGetsql 通过文件内容获取的sql语句
// FullName: myGetsql
// Access: public 
// Returns: int
// Qualifier: insertData()
// Parameter: FILE * file 导入数据的文件名
// Parameter: int maxSize 文件里每行记录的最大长度
// Parameter: char * tableName 需要插入数据库的表名
// Parameter: char ** sql sql执行语句
// Parameter: int fields 字段数
// Parameter: int * format 每个字段的格式，数字:1，字符(串):0
//************************************
int myGetsql(FILE *file,char **sql,int fields,int *format) ;
这个函数的作用就是从文件中获取格式化的内容并返回sql语句。很容易理解。
这个函数的唯一调用者就是insertData()函数了。
//************************************
// Method:    join 将字符串b接在字符串a后面
// FullName:  join
// Access:    public 
// Returns:   void
// Qualifier:
// Parameter: char * * a 原始字符串
// Parameter: char * * b 需要添加的字符串
//************************************
void join(char **a,char **b);
这个函数的作用就是把一个字符串添加到另一个字符串的后面，相当于c语言中的字符串的"+"操作符了。

接下来就是全部的代码了。
#include "stdio.h"
#include "io.h"
#include "stdlib.h"
#include "string.h"
#include "sqlite3.h"
#include "time.h"

#define STR 0
#define NUM 1

void join(char **,char**);
int myGetsql(FILE *,int,char *,char **,int *);
int insertData(sqlite3 *,int *);

int main(int argc,char *argv[])
{
    clock_t t1 = clock();
    sqlite3 *db;
    int rc;
    char *ErrMsg = 0;
    const char *dbname = "DBforCourse.db3";
    if(!access(dbname,0)){
         if(0!=remove("DBforCourse.db3")){
            printf("删除文件失败!\n");
        }
    }

    rc = sqlite3_open("DBforCourse.db3",&db);
    if (rc){
        fprintf(stderr,"Can't open database: %s\n",sqlite3_errmsg(db));
        exit(0);
    }
    //创建数据库表
    char *College = "create table College(cName VARCHAR(20),state VARCHAR(20),enrollment int)";
    char *Student = "create table Student(sID int,sName VARCHAR(20),GPA real,sizeHS int)";
    char *Apply = "create table Apply(sID int,cName VARCHAR(20),major VARCHAR(20),decision VARCHAR(10))";
    sqlite3_exec(db,College,0,0);
    sqlite3_exec(db,Student,Apply,0);

    //插入数据
    int college[3] = { STR,STR,NUM };
    int apply[4] = {NUM,STR};
    int student[4] = {NUM,NUM,NUM};

    if(!insertData(db,"dbcollege.txt",200,"College",3,college))
        printf("插入College表失败!\n");
    if(!insertData(db,"dbapply.txt","Apply",4,apply))
        printf("插入Apply表失败!\n");
    if(!insertData(db,"dbstudent.txt","Student",student))
        printf("插入Student表失败!\n");
    sqlite3_close(db);
    clock_t t2 = clock();
    printf("耗时%ld毫秒\n",t2-t1);

}

//************************************
// Method: myGetsql 通过文件内容获取的sql语句
// FullName: myGetsql
// Access: public 
// Returns: int
// Qualifier:
// Parameter: FILE * file 导入数据的文件名
// Parameter: int maxSize 文件里每行记录的最大长度
// Parameter: char * tableName 需要插入数据库的表名
// Parameter: char ** sql sql执行语句
// Parameter: int fields 字段数
// Parameter: int * format 每个字段的格式，数字:1，字符(串):0
//************************************
int myGetsql(FILE *file,int *format) {
    int i,s = 0,k = 0;
    char *query[fields];
    char input[maxSize];
    char *enter;

    char *a0 = "insert into ";
    char *a1 = " values(";
    char *a2 = ",";
    char *a3 = "'";
    char *a4 = "',";
    char *a5 = ")";

    *sql = a0;
    join(sql,&tableName);
    join(sql,&a1);

    if (fgets(input,maxSize,file)){
        i = 0;
        //删除末尾的\n符
        if (enter = strchr(input,'\n'))
            *enter = '\0';
        query[i] = strtok(input,",");
        while (query[++i] = strtok(0,")){}

        for (s = 0; s < fields - 1; s++){
            if (*(format + s)){//数字
                join(sql,&query[s]);
                join(sql,&a2);
            }
            else{//字符串
                join(sql,&a3);
                join(sql,&a4);
            }
        }
        if (*(format + s)){//数字
            join(sql,&query[s]);
        }
        else{//字符串
            join(sql,&a3);
            join(sql,&query[s]);
            join(sql,&a3);
        }
        join(sql,&a5);
        k = 1;
    }
    else
        k = 0;
    return k;
}

//************************************
// Method: join 将字符串b接在字符串a后面
// FullName: join
// Access: public 
// Returns: void
// Qualifier:
// Parameter: char * * a 原始字符串
// Parameter: char * * b 需要添加的字符串
//************************************
void join(char **a,char **b)
{
    size_t size = strlen(*a) + strlen(*b) + 1;
    char *result = (char *)malloc(size);
    strcpy(result,*a);
    strcat(result,*b);
    free(*a);
    *a = result;
}


//************************************
// Method: insertData 从文件中读取记录并插入数据库
// FullName: insertData
// Access: public 
// Returns: int
// Qualifier:
// Parameter: sqlite3 * db sqlite3实例指针
// Parameter: char * fileName 要读取内容的文件名
// Parameter: int maxSize 每行记录的最大长度
// Parameter: char * tableName 要插入数据的表名
// Parameter: int length 字段数
// Parameter: int * format 每个字段的格式，数字:1，字符(串):0
//************************************
int insertData(sqlite3 *db,int *format){
    FILE *file;
    if (!(file = fopen(fileName,"r"))){
        printf("打开文件%s失败!\n",fileName);
        return 0;
    }
    char *sql = 0;
    sqlite3_exec(db,"begin;",0);
    while (myGetsql(file,tableName,&sql,length,format)){
        if (sqlITE_OK != sqlite3_exec(db,sql,0))
            printf("%s 语句执行失败!\n",sql);
    }
    fclose(file);
    sqlite3_exec(db,"commit;",0);
    return 1;
}

原文地址：https://www.jb51.cc/sqlite/199567.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Java 嵌入数据处理引擎：SQLite 的挑战者 esProc SPL
SQLite架构简单，又有Json计算能力，有时会承担Json文件/RESTful的计算功能，但SQLite不能直接解析Json文件/RESTful，需要用Java代码硬写，或借助第三方类库，最后再拼成insert语句插入数据表，代码非常繁琐，这里就不展示了。参考前面的代码可知，入库的过程比较麻烦，不能只用SQL，还要借助Java或命令行。SPL是现代的数据计算语言，属于简化的面向对象的语言风格，有对象的概念，可以用点号访问属性并进行多步骤计算，但没有继承重载这些内容，不算彻底的面向对象语言。...
五、使用Python操作数据库
使用Python操作内置数据库SQLite以及MySQL数据库。
AndroidStudio-实现登录界面数据存储在SQLite
登陆界面
一文教会你导出微信聊天记录
破解微信数据库密码，用python导出微信聊天记录
UnitySqlite持久化数据
（Unity）SQLite 是一个软件库，实现了自给自足的、无服务器的、零配置的、事务性的 SQL 数据库引擎。SQLite 是在世界上最广泛部署的 SQL 数据库引擎。SQLite 源代码不受版权限制。本教程将告诉您如何使用 SQLite 编程，并让你迅速上手。.................................
Android用户登陆与注册功能的简单实现SQLite
安卓开发，利用SQLite实现登陆注册功能
SQLite——Java使用SQLite初体验
相比大多数数据库而言，具有等优势，广泛应用于、等领域。
使用SqlSugar连接多个数据库sqlserver，sqlite，mysql
有时候，一个项目只有一个数据库，比如只有SQLite，或者MySQL数据库，那么我们只需要使用一个固定的数据库即可。但是一个项目如果写好了，有多个用户使用，但是多个用户使用不同的数据库，这个时候，我们就需要把软件设计成可以连接多个数据库的模式，用什么数据库，就配置什么数据库即可。4.Users实体类，这个实体类要和数据库一样的，形成一一对应的关系。11.Sqlite数据库，需要在代码里面创建数据库，建立表，再建立数据。8.我们开启MySQL数据库，然后进行调试，看程序的结果。2.安装SqlSugar。
基于Android的背单词软件【源码+文档+答辩PPT】
基于Android的背单词软件，功能强大完整。
python ——操作sqlite 数据库
SQLite，是一款轻型的数据库，是遵守ACID的关系型数据库管理系统。说白了就是使用起来轻便简单，
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot