sqlite在ARM板上的存取速度的问题

a_jige

我在arm板上 执行插入操作，如果用transaction平均每秒只能执行500次。。而且，速度与不用transaction差别并不明显。执行update时候，速度就更慢了。。
同样的程序在计算机上运行， 每秒可以插入30000次。请问，这个正常吗？
以下是我的程序，请问是程序的问题吗？

1. #include <stdio.h>
   
2. #include "sqlite3.h"
   
3. #include <stdlib.h>
   
4. #include <time.h>
   
5. 
   
6. static int callback(void *NotUsed, int argc, char **argv, char **azColName)
   
7. {
   
8.   int i;
   
9.   for(i=0; i<argc; i++)
   
10.   {
    
11.   printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    
12.   }
    
13.   printf("\n");
    
14.   return 0;
    
15. }
    
16. 
    
17. int printtime()
    
18. {
    
19. 
    
20.   time_t ts;
    
21.   struct tm struTmNow;
    
22.   time(&ts);
    
23.   localtime_r(&ts, &struTmNow);
    
24.   printf("%d:%d:%d ",struTmNow.tm_hour, struTmNow.tm_min,struTmNow.tm_sec);
    
25. 
    
26. }
    
27. 
    
28. int main(int argc, char **argv)
    
29. {
    
30.   sqlite3 *db;
    
31.   char *zErrMsg = 0;
    
32.   int rc;
    
33.   int i ;
    
34.   char query[500];
    
35.   int loopnum = atoi(argv[2]);
    
36. 
    
37.   rc = sqlite3_open(argv[1], &db);
    
38.   if( rc!= SQLITE_OK )
    
39.   {
    
40.   fprintf(stderr, "Can't open database: %s\n", sqlite3_errmsg(db));
    
41.   sqlite3_close(db);
    
42.   exit(1);
    
43.   }
    
44. 
    
45.   sprintf(query, "create table wutbl (test1 int, test2 int, test3 int ,test4 int, test5 int, test int, test7 int, test8 int, test9, test10 int)");
    
46. 
    
47.   rc = sqlite3_exec(db, query, callback, 0, &zErrMsg);
    
48.   if( rc!=SQLITE_OK )
    
49.   {
    
50.   fprintf(stderr, "SQL error: %s\n", zErrMsg);
    
51.   sqlite3_free(zErrMsg);
    
52.   }
    
53.   printf("time before insert:");
    
54.   printtime();
    
55.   printf("\n");
    
56.   rc = sqlite3_exec(db, "BEGIN; ", 0, 0, &zErrMsg);
    
57. 
    
58.   for (i = 0; i < loopnum; i++)
    
59.   {
    
60.   sprintf(query, "insert into wutbl values (%d,%d, %d, %d, %d, %d, %d, %d, %d, %d);", i,
    
61. i,i,i,i,i,i,i,i,i);
    
62.   rc = sqlite3_exec(db, query, 0, 0, &zErrMsg);
    
63.   if (rc != SQLITE_OK)
    
64.   break;
    
65.   }
    
66. 
    
67.   if(i!= loopnum)
    
68.   {
    
69.   sqlite3_exec(db,"ROLLBACK:",0,0,&zErrMsg);
    
70.   printf("i = %d rollback\n",i);
    
71.   sqlite3_close(db);
    
72.   exit;
    
73.   }
    
74.   else
    
75.   {
    
76.   rc = sqlite3_exec(db, "COMMIT; ", 0, 0, &zErrMsg);
    
77.   printf(" time after %d insert:",i ) ;
    
78.   printtime();
    
79.   printf("\n");
    
80.   }
    
81. 
    
82.   printf("time before update:");
    
83.   printtime();
    
84.   printf("\n");
    
85.   rc = sqlite3_exec(db, "BEGIN; ", 0, 0, &zErrMsg);
    
86. 
    
87.   for (i = 0; i < loopnum; i++)
    
88.   {
    
89.   sprintf(query, "update wutbl set test2= %d where test1 = %d;", i+2,i);
    
90.   rc = sqlite3_exec(db, query, 0, 0, &zErrMsg);
    
91.   if (rc != SQLITE_OK)
    
92.   break;
    
93.   }
    
94. 
    
95.   if(i!= loopnum)
    
96.   {
    
97.   sqlite3_exec(db,"ROLLBACK:",0,0,&zErrMsg);
    
98.   printf("i = %d rollback\n",i);
    
99.   exit;
    
100.   }
     
101.   else
     
102.   {
     
103.   rc = sqlite3_exec(db, "COMMIT; ", 0, 0, &zErrMsg);
     
104.   printf(" time after %d update:",i ) ;
     
105.   printtime();
     
106.   printf("\n");
     
107.   }
     
108. 
     
109. 
     
110. 
     
111. 
     
112.   sqlite3_close(db);
     
113.   return 0;
     
114. }

复制代码

crifan

不熟悉，不过想问问你的数据库的数据，是在内存中，还是在flash等存储介质中的？
如果是前者，那PC上也是前者的话，那估计就和CPU频率高低有关系了；
如果是后者，数据读写nor或nand flash，肯定比PC上的硬盘，要慢不少的，再加上板子上cpu也没PC上cpu快啊，所以你这个也就是在正常范围内了。

caijicheng2006

这个问题我遇到过，我当时用MIPS的板子。
主要问题如下：

1. 如果你的文件系统是yaffs2的话不会太慢，如果是ext3或ext4的话会非常慢，500条记录要用3秒左右。
2. 在用sqlite3时，如果使用事务处理会快很多。
3. 如果你是ext3或ext4的文件系统，而且你用了事务处理还很慢的话，有一招把你的.DB文件放到/tmp目录下，就相当是放在内存中。
然后从文件系统中建立一个连接到/tmp/*.db。记得每次开机就把*.db拷贝到/tmp，关机前把/tmp/*.db拷贝回文件系统。

事务处理：
#include <stdio.h>
#include <stdlib.h>
#include "include/sqlite3.h"
#include <sys/time.h>

#define _DEBUG_
#define NUM  1000

int main(void)
{
        sqlite3 *db=NULL;
        char *err_msg=0;
        int rc;
        char *sql="CREATE TABLE SensorData(\
        ID INTEGER PRIMARY KEY,\
        SensorID INTEGER,\
        SiteNum INTEGER,\
        Time VARCHAR(12),\
        SensorParameter REAL\
        );";
        int nrow = 0, ncolumn = 0;
        char **azResult; //二维数组存放结果
        int i = 0;
        struct timeval tv;
        char sql_tmp[100];

        rc = sqlite3_open("a.db", &db);
        if (rc) {
                fprintf(stderr, "Can't open database:%s\n", sqlite3_errmsg(db));
                sqlite3_close(db);
                exit(1);
        }else{
                printf("open database success !\n");
        }
       
        sqlite3_exec(db, sql, 0, 0, &err_msg);
#ifdef _DEBUG_
        printf("%s :%s\n", __func__, err_msg);
#endif
        // 插入数据
        gettimeofday(&tv, NULL);
        printf("before insert Sensor time=%ld\n", tv.tv_sec);
        #if 0
                sql = "INSERT INTO SensorData VALUES(NULL, 1, 1, '200605011206', 18.9);";
                sqlite3_exec(db, sql, 0, 0, &err_msg);
                sql = "INSERT INTO SensorData VALUES(NULL, 1, 1, '200605011306', 16.4);";
                sqlite3_exec(db, sql, 0, 0, &err_msg);
        #else
                sqlite3_exec(db, "begin;", 0, 0, &err_msg);
                for (i = 0; i < NUM; i++) {
                        sprintf(sql_tmp, "INSERT INTO SensorData VALUES(NULL, %d, 1, '201004271541', 17.1)", i);
                        // printf("sql_tmp = %s\n", sql_tmp);
                        sqlite3_exec(db, sql_tmp, 0, 0, &err_msg);
                }
                sqlite3_exec(db, "commit;", 0, 0, &err_msg);
        #endif
        gettimeofday(&tv, NULL);
        printf("after insert Sensor time=%ld\n", tv.tv_sec);
//查询数据
/*
        int sqlite3_get_table(sqlite3*, const char *sql,char***result , int *nrow , int *ncolumn ,char **errmsg );
        result中是以数组的形式存放你所查询的数据，首先是表名，再是数据。
        nrow ,ncolumn分别为查询语句返回的结果集的行数，列数，没有查到结果时返回0
*/
        sql = "SELECT * FROM SensorData ";
        sqlite3_get_table(db, sql, &azResult, &nrow, &ncolumn, &err_msg);
        printf("row:%d column=%d", nrow, ncolumn);
        printf("The result of querying is :");
        for( i=0 ; i<( nrow + 1 ) * ncolumn ; i++ )
                printf( "azResult[%d] = %s\n", i , azResult[i] );
        //释放掉 azResult 的内存空间
        sqlite3_free_table( azResult );
#ifdef _DEBUG_
        printf("%s:err_msg = %s\n",__func__, err_msg);
#endif


        sqlite3_close(db);
        return 0;       
}