(C#版本)提升SQlite数据库效率——开启事务,极速插入数据,3秒100万,32秒1000万条数据

时间:2023-03-08 17:52:42

SQLite插入数据效率最快的方式就是:开启事务  +   insert语句  +  关闭事务(提交)

利用事务的互斥性,如果在批量的插入操作前显式地开启一次事务,在插入操作结束后,提交事务,那么所有的操作将只执行一次事务,大大地提高IO效率

开启事务和提交事务时缺省的,如果不显式写出来,将在每次insert语句前开启事务,insert语句后提交,如果执行insert语句1000万次,那么将自动开启并提交1000万次!!!

可以尝试,去掉下面代码中两行红色代码,速度将显著下降!!!

 using System;
using System.IO;
using System.Data.SQLite;
using System.Diagnostics;
using System.Data.Common; namespace SqliteTran
{
class Program
{
static void Main(string[] args)
{
DbProviderFactory Dbfactory = SQLiteFactory.Instance;
using (DbConnection dbConn = Dbfactory.CreateConnection())
{
//连接数据库
File.Delete("NBA.db4");
dbConn.ConnectionString = "data source = NBA.db4";
dbConn.Open();
//创建数据表
string sql = "create table Garnett ([age] INTEGER PRIMARY KEY, [s] TEXT COLLATE NOCASE)";
DbCommand cmd = dbConn.CreateCommand();
cmd.Connection = dbConn;
cmd.CommandText = sql;
cmd.ExecuteNonQuery(); // 添加参数
cmd.Parameters.Add(cmd.CreateParameter());
// 开始计时
Stopwatch watch = new Stopwatch();
watch.Start(); DbTransaction trans = dbConn.BeginTransaction();
// 连续插入记录
for (int i = ; i < ; i++)
{
cmd.CommandText = "insert into Garnett ([s]) values (?)";
cmd.Parameters[].Value = i.ToString();
cmd.ExecuteNonQuery();
}
trans.Commit();
dbConn.Close();
// 停止计时
watch.Stop();
Console.WriteLine(watch.Elapsed);
Console.ReadLine();
}
}
}
}

不开启事务,插入1k行

(C#版本)提升SQlite数据库效率——开启事务,极速插入数据,3秒100万,32秒1000万条数据

开启事务,插入100w行

(C#版本)提升SQlite数据库效率——开启事务,极速插入数据,3秒100万,32秒1000万条数据