/**************************************************************************

 *                     C语言SQLite3基本操作Demo

 * 声明：

 *      1. 本文仅仅是为了写一个C语言SQLite3的Demo;

 *      2. 本文并没有说明如何在终端下进入SQLite3创建数据库，也没有解释

 *          sql语句的概念，仅仅给出了代码示例，这些内容需要你自己去

 *          资料。

 *

 *                                  2015-7-4 晴 深圳 南山平山村 曾剑锋

 *************************************************************************/

                       \\\\\\\-*- 目录-*-///////

                       |  一、cat user.h

                       |  二、cat user.c

                       |  三、cat main.c

                       |  四、cat Makefile

                       |  五、cat user.sql

                       \\\\\\\\\\\\\///////////

一、cat user.h

    #ifndef __USER_H__

        #define __USER_H__

        #include <stdio.h>

        #include <stdlib.h>

        #include <sqlite3.h>

        #include <string.h>

        // 使用结构体来保存数据库中的数据

        typedef struct USER {

            char id[];             // 保存数据库中的id

            char name[];          // 姓名

            char password[];      // 密码

            char startTime[];     // 用户创建的开始时间

            struct USER* next;      // 数据从数据库中提取出来是用链表保存

        } User;

        // 查询user表Demo

        void userDemo(void);

        // 查询数据时的回调函数

        static int select_callback(void* data, int col_count, char** col_values, char** col_name);

        // 打印UserLinked链表

        void printUserLinked(User* userLinked);

        // 获取UserLinked链表

        User* getUserLinked(char* sql);

        // 释放链表中的数据

        void freeUserLinked(User* userLinked);

        // 更新数据库

        int updateUserDB(char* sql);

    #endif

二、cat user.c

    #include "user.h"

    // 存放链表的表头

    static User* userLinkedHead = NULL;

    // 存放当前记录的结构体地址

    static User* userCurrent = NULL;

    void userDemo(void){

        // 获取用户链表

        User* userLinked = getUserLinked("select * from user;");

        // 打印用户链表

        printUserLinked(userLinked);

        // 释放用户链表

        freeUserLinked(userLinked);

    }

    // 查询数据库时的回调函数

    static int select_callback(void* data, int col_count, char** col_values, char** col_name){

        int i;

        userCurrent = calloc(, sizeof(User));

        for (i = ; i < col_count; i++) {

            if(strcmp(col_name[i], "id") == ){

                strcpy(userCurrent->id, col_values[i]);

            }

            if(strcmp(col_name[i], "name") == ){

                strcpy(userCurrent->name, col_values[i]);

            }

            if(strcmp(col_name[i], "password") == ){

                strcpy(userCurrent->password, col_values[i]);

            }

            if(strcmp(col_name[i], "startTime") == ){

                strcpy(userCurrent->startTime, col_values[i]);

            }

        }

        // 创建链表头

        if(userLinkedHead == NULL){

            userLinkedHead = userCurrent;

            return ;

        }

        // 采用头插的方式插入链表

        userCurrent->next = userLinkedHead->next;

        userLinkedHead->next = userCurrent;

        return ;

    }

    // 将链表中的数据打印出来

    void printUserLinked(User* userLinked){

        User* userCurrent = userLinked;

        while(userCurrent){

            printf("id = %s\n", userCurrent->id);

            printf("name = %s\n", userCurrent->name);

            printf("password = %s\n", userCurrent->password);

            printf("startTime = %s\n", userCurrent->startTime);

            userCurrent = userCurrent->next;

        }

    }

    // 当程序退出的时候，要释放堆中的内存空间

    void freeUserLinked(User* userLinked){

        User* freeCurrent = userLinked;

        User* freePre = userLinked;

        while(freeCurrent){

            freeCurrent = freePre->next;

            free(freePre);

            freePre = freeCurrent;

        }

        userLinkedHead = NULL;

    }

    // 通过传入查询sql字符串来获取查询的链表

    User* getUserLinked(char* sql){

        sqlite3 *db;

        sqlite3_open("./user.db", &db);

        sqlite3_exec(db, sql, select_callback, , NULL);  

        sqlite3_close(db);

        db = ;

        return userLinkedHead;

    }

    // 通过sql来更新数据库

    int updateUserDB(char* sql){

        sqlite3 *db;

        sqlite3_open("./user.db", &db);

        sqlite3_exec(db, sql, NULL, NULL, NULL);  

        sqlite3_close(db);

        db = ;

        return ;

    }

三、cat main.c

    #include "user.h"

    int main(int argc, char** argv){

        userDemo();

        return ;

    }

四、cat Makefile

    user: user.o main.o

        gcc user.o main.o -lsqlite3 -o user

    user.o: user.h

        gcc -c user.c

    main.o: user.h

        gcc -c main.c

    clean:

        rm -rf *.o user

五、cat user.sql

    #创建表，id为自动增长

    create table user (

        id integer PRIMARY KEY AUTOINCREMENT,

        name varchar(),

        password varchar(),

        startTime timestamp

    );

    #插入初始值

    insert into user (name, password, startTime) values ('zjf', 'zjf', current_timestamp);

    insert into user (name, password, startTime) values ('lt', 'lt', current_timestamp);

    insert into user (name, password, startTime) values ('cyq', 'cyq', current_timestamp);

    #查询

    select * from user;

    select * from user where name='zjf';

    #日期的使用

    select date('now');

    select time('now');

    select datetime('now');

    select jolianday('now')-jolianday('1981-12-23');

    select strftime('%Y.%m.%d', 'now');

    select strftime('%Y.%m.%d', 'now', 'localtime');

    #带日期的查询

    select id, name, password, date(startTime) from user;

    select id, name, password, time(startTime) from user;

    select id, name, password, datetime(startTime) from user;

    #删除表

    drop table user;