一、C/C++ 介面 API

主要通過通過sqlite3_open，sqlite3_exec和qlite3_close來實現一個簡單的資料庫操作。

1.1、sqlite3_open

sqlite3_open(const char *filename, sqlite3 **ppDb)

• 開啟一個指向 SQLite 資料庫檔案的連線，返回一個用於其他 SQLite 程式的資料庫連線物件
• filename 引數是 NULL 或':memory:'，sqlite3_open() 將會在 RAM 中建立一個記憶體資料庫，這隻會在 session 的有效時間內持續
• filename不為NULL，sqlite3_open()
  將使用這個引數值嘗試開啟資料庫檔案。如果該名稱的檔案不存在，sqlite3_open() 將建立一個新的命名為該名稱的資料庫檔案並開啟

1.2、sqlite3_exec

sqlite3_exec(sqlite3*, const char *sql, sqlite_callback, void *data, char **errmsg)

• 提供了一個執行 SQL 命令的快捷方式，SQL 命令由 sql 引數提供，可以由多個 SQL 命令組成
• 第一個引數sqlite3是開啟的資料庫物件，sqlite_callback是一個回撥data作為其第一個引數errmsg將被返回用來獲取程式生成的任何錯誤
• sqlite3_exec()程式解析並執行由sql引數所給的每個命令，直到字串結束或者遇到錯誤為止

1.3、sqlite3_close

sqlite3_close(sqlite3*)

• 關閉之前呼叫 sqlite3_open() 開啟的資料庫連線。所有與連線相關的語句都應在連線關閉之前完成。如果還有查詢沒有完成，sqlite3_close() 將返回 SQLITE_BUSY 禁止關閉的錯誤訊息

1.4、插入例程

void jobSerialInsertSQL(struct S_SERIAL_JOB serialjob)
{

	char* insertJob;
	char sql[255
 
];
	sqlite3 *db;
	int rc;
	char *zErrMsg = 0;
    rc = sqlite3_open("jp.db",&db);
    if(rc)
    {
        printf("Can not open database:%s\n",sqlite3_errmsg(db));
        return;
    }

	insertJob = "INSERT INTO rt_jobserial (task_serial,task_id,point_tag,device_tag) VALUES (";
	sprintf(sql,"%s%d%s%d%s%d%s%d%s",
				insertJob,
				serialjob.task_serial,
				",",
				serialjob.task_id,
				",",
				serialjob.point_tag,
				",",
				serialjob.device_tag,
				")");
    rc = sqlite3_exec(db,sql,sqliteCallback,0,&zErrMsg);
    if( rc != SQLITE_OK)
    {
        printf("SQL ERROR: %s\n",zErrMsg);
        sqlite3_free(zErrMsg);
    }
    else{}
    sqlite3_close(db);

}

經過測試，上面程式碼在for迴圈執行插入1500條資料大約耗時1~2分鐘，效率很低，在工程中是無法滿足需求的。

預設SQLite的資料庫插入操作，如果沒有采用事務的話，它每次寫入提交，就會觸發一次事務操作，而這樣幾千條的資料，就會觸發幾千個事務的操作，這就是時間耗費的根源。

二、事務實現

2.1、什麼是事務？

事務是使用者定義的一些列資料操作，這些操作是一個完整的不可分的工作單元。一個事務要麼全部執行，要麼全部不執行。

2.2、事務屬性（ACID）

原子性(Atomicity)： 確保工作單位內的所有操作都成功完成，否則，事務會在出現故障時終止，之前的操作也會回滾到以前的狀態。
一致性(Consistency)：確保資料庫在成功提交的事務上正確地改變狀態。
隔離性(solation)： 使事務操作相互獨立和透明。
永續性(Durability)： 確保已提交事務的結果或效果在系統發生故障的情況下仍然存在。

2.3、事務控制

事務控制命令只與 DML 命令 INSERT、UPDATE 和DELETE一起使用。他們不能在建立表或刪除表時使用，因為這些操作在資料庫中是自動提交的。

• BEGIN TRANSACTION：開始事務處理。
• COMMIT：儲存更改，或者可以使用 END TRANSACTION 命令。
• ROLLBACK：回滾所做的更改。

2.4、事務例程

void jobSerialInsertSQL(struct S_SERIAL_JOB *serialjob,int totalNum)
{
	char* insertJob;
	char sql[255];
	sqlite3 *db;
	int rc;
	char *zErrMsg = 0;
	int i = 0;
	bool isExecSuccess = true;
    rc = sqlite3_open("jp.db",&db);
    if(rc)
    {
        printf("Can not open database:%s\n",sqlite3_errmsg(db));
        return;
    }
    sqlite3_exec(db, "begin;", 0, 0, &zErrMsg); //開啟事務
	insertJob = "INSERT INTO rt_jobserial (task_serial,task_id,point_tag,device_tag) VALUES (";
	for(i=0;i<totalNum;i++)
	{
			sprintf(sql,"%s%d%s%d%s%d%s%d%s",
				insertJob,
				serialjob[i].task_serial,
				",",
				serialjob[i].task_id,
				",",
				serialjob[i].point_tag,
				",",	
				serialjob[i].device_tag,
				")");
			rc = sqlite3_exec(db,sql,sqliteCallback,0,&zErrMsg);
			memset(sql,0,255);
			if( rc != SQLITE_OK)
			{
				isExecSuccess = false;
				printf("SQL ERROR: %s\n",zErrMsg);
				sqlite3_free(zErrMsg);
			}
			else{}
	}
	if(isExecSuccess)
	{
		sqlite3_exec(db, "commit;", 0, 0, 0); 
	}
	else
	{
		sqlite3_exec(db, "rollback;", 0, 0, 0); 
	}
    sqlite3_close(db);
}

經過測試，上面程式碼插入1500條資料所需時間約為 70~90 ms。