【原创】sqlite线程安全实验【chad20130201】

编译sqlite时使用默认配置，启用了线程安全设置。

实验程序如下：

int Query_db( char* db_file_name )
{
    printf("in %s\n",__FUNCTION__);
    int    ret;
    sqlite3_stmt    *pstmt = NULL;
    char    *errMsg = NULL;
    char    *sql = "SELECT * FROM MonthFreezeTable WHERE id<500;";//查询表中有多少列
    int    id;
    STRUCT_TEST1    test_struct1;
    STRUCT_TEST2    test_struct2;

    memset(&test_struct1,0,sizeof(test_struct1));
    memset(&test_struct2,sizeof(test_struct2));

    ret = sqlite3_prepare(pdb,sql,strlen(sql),&pstmt,&errMsg);
     if( ret != sqlITE_OK )
    {
        printf("error code :%d,reason:%s\n",ret,errMsg);
        sqlite3_free( errMsg );
        return -1;
    }/*这一部分程序有问题*/
    while( 1 )
    {
        ret = sqlite3_step(pstmt);
        if( ret != sqlITE_ROW )
        {    break; }
        id = sqlite3_column_int(pstmt,0);
        printf("id = %d ",id);
        usleep(10000);
    }
    sqlite3_finalize( pstmt ); //把刚才分配的内容析构掉
    sqlite3_reset( pstmt );

    return 0;

}
int    UpdateBlobData(char *db_file_name)
{
    printf("in %s\n",__FUNCTION__);
    int    ret;
    sqlite3_stmt    *pstmt = NULL;
    char    *errMsg = NULL;
    char    sql[1023];// = "UPDATE MonthFreezeTable SET TimeScale=datetime(),ForwardPowerInd=:forw WHERE id>0;";
    int        index1,index2;
    char    *timebuf="2010-11-11";
    clock_t starttime,endtime;
    double totaltime;
    starttime = clock();

    printf("start update the db \n");
    int i ;
    for(i=0;i<441;i++){
        printf("%10d",i);
        //timebuf = Now();
        //printf("Now:%s",timebuf);
        sprintf(sql,"UPDATE MonthFreezeTable SET TimeScale=datetime(),ForwardPowerInd=:forw WHERE id=%d;",i);
        ret = sqlite3_prepare(pdb,&errMsg);//预编译
        if( ret != sqlITE_OK )
        {
            printf("error code :%d,errMsg);
            sqlite3_free( errMsg );
            return -1;
        }
        index2 = sqlite3_bind_parameter_index( pstmt,":forw" );//生成索引 
        ret = sqlite3_bind_blob(pstmt,index2,10,sqlITE_STATIC);//绑定数据流 
        if( ret != sqlITE_OK )
        {
            printf("the sqlite3_bind_blob error!\n");
            printf("error code :%d \n",ret);
            return -1;
        }
    restep:
        sqlite3_busy_timeout(pdb,1000);
        ret = sqlite3_step(pstmt);//执行
        if( ret != sqlITE_DONE )
        {
            if( ret == sqlITE_BUSY ){//sqlITE_BUSY
                printf("step timeout!\n");
                goto restep;
            }
            printf("the sqlite3_step error!\n");
            printf("error code :%d \n",ret);
            return -1;
        }
    }
    printf("end update the db \n");
    endtime = clock();
    totaltime = (double)( (endtime - starttime)/(double)CLOCKS_PER_SEC );
    printf("the total time = %f s\n",totaltime);
    printf("the step time = %f ms\n",(totaltime*1000)/(12*2041));

    sqlite3_finalize( pstmt ); //把刚才分配的内容析构掉
    sqlite3_reset( pstmt );

    return 0;
}

实验1：两个线程（进程同时进行数据查询操作！）

int main(void)
{
    int ret;

    ret = Create_db( "/home/terminal.db" );
    if(ret < 0)
    {
        return -1;
    }
    int pid = fork();
    if(pid < 0) {
        perror("fork error!\n");
        return 0;
    }
    if(pid==0){
        printf("the child pross!\n");
        ret = Query_db( "/home/terminal.db" );
        if(ret < 0)
        {
            return -1;
        }
        printf("child sleep 5!\n");
        sleep(5);
    }else{
        printf("the father pross!\n");
        ret = Query_db( "/home/terminal.db" );
        if(ret < 0)
        {
            return -1;
        }
        sleep(5);
        printf("father sleep 5!\n");
    }

    sqlite3_close(pdb);

    return 0;
}

打印结果如下所示：（示例） @H_580_301@ @H_580_301@ 如上图红色部分所示，两个进程分别交叉打印查询结果，这说明：sqlite3多线程查询互不影响，是线程安全的。 @H_580_301@ 实验2：一个进程进行查询，一个进程进行更新操作，代码片段如下：

int pid = fork();
    if(pid < 0) {
        perror("fork error!\n");
        return 0;
    }
    if(pid==0){
        printf("the child pross!\n");
        ret = UpdateBlobData( "/home/terminal.db" );
        if(ret < 0)
        {
            return -1;
        }
        printf("child sleep 5!\n");
        sleep(5);
    }else{
        printf("the father pross!\n");
        ret = Query_db( "/home/terminal.db" );
        if(ret < 0)
        {
            return -1;
        }
        sleep(5);
        printf("father sleep 5!\n");
    }

执行结果如下： @H_580_301@ @H_580_301@ 结果如上，程序先运行了父进程，但是父进程的sqlite3_step(pstmt)返回了超时，同时，子进程的查询操作正确执行。待子进程查询完毕退出后父进程的更新操作才继续进行。这说明：sqlite的线程安全是有效的，当有数据更新操作时，更新操作是安全的互斥的，所以，编程时不需要专门编写线程锁程序对数据库操作进行保护。

由于sqlite仅仅提供了粒度很粗的数据锁，如读写锁，因此在每次加锁操作中都会有大量的数据被锁住，即使仅有极小部分的数据会被访问。换句话说，我们可以认为sqlite只是提供了表级锁，没有提供行级锁。在这种同步机制下，并发性能很难高效。