最近接手一个任务:向SQLSERVER数据库录入两亿条测试数据,原本打算用存储过程来操作,但是嫌麻烦,开发了一个用控制台向数据库循环录入的小Deom。
因为不知道怎么去写代码,可能有些地方不是太对,希望各路大神指出。
首先是创建一个控制台程序(这个不多说,大家都会)
先连接数据库
private static readonly string conStr = "Password=密码;User ID=用户名;Initial Catalog=数据库名;Data Source=.";
写一个你准备录入的数据,我是测试所以只循环录入了二百万条数据
private static int x = 2000000;
接下来就是循环录入了
static void Main(string[] args)
{
InsertSql();
Console.ReadKey();
}
static void InsertSql()
{
Stopwatch sw = new Stopwatch();
DataTable dt = GetTables();
try
{
using (SqlConnection conn = new SqlConnection(conStr))
{
SqlBulkCopy bulkCopy = new SqlBulkCopy(conn);
bulkCopy.DestinationTableName = "UserInfo";
bulkCopy.BatchSize = dt.Rows.Count;
conn.Open();
sw.Start();
for (int i = 0; i < x; i++)
{
DataRow dr = dt.NewRow();
dr[0] = i; //这里是Id,因为我在数据库把Id设置的是自增,但是在这里不加这个Id还一直报错,找了半天,还是不明白,这里加入,Id还不是从1开始的。希望有大神指出,让我也明白一下,多谢。
dr[1] = i + "";
dr[2] = i + "";
dr[3] = i + "";
dr[4] = i % 3;
dr[5] = "Code-" + i;
dr[6] = i % 5;
dr[7] = i % 3;
dr[8] = "图片路径" + i;
dr[9] = "图片名称" + i;
dr[10] = DateTime.Now.ToString("yyyy-MM-dd hh:ss:mm");
dr[11] = DateTime.Now.ToString("yyyy-MM-dd hh:ss:mm");
dt.Rows.Add(dr);
}
if (dt != null && dt.Rows.Count > 0)
{
bulkCopy.WriteToServer(dt);
sw.Stop();
}
Console.WriteLine("插入{0}条记录共花费{1}毫秒", x, sw.ElapsedMilliseconds);
}
}
catch (Exception ex)
{
throw ex;
}
}
然后是获取DateTable的数据了
static DataTable GetTables()
{
DataTable dt = new DataTable();
dt.Columns.AddRange(new DataColumn[] {
new DataColumn("Id",typeof(int)),
new DataColumn("Name",typeof(string)),
new DataColumn("Sex",typeof(string)),
new DataColumn("NameA",typeof(string)),
new DataColumn("SexA",typeof(int)),
new DataColumn("NameCode",typeof(string)),
new DataColumn("NameType",typeof(int)),
new DataColumn("SexB",typeof(int)),
new DataColumn("NamePath",typeof(string)),
new DataColumn("NameImg",typeof(string)),
new DataColumn("NameTime",typeof(DateTime)),
new DataColumn("NameDate",typeof(DateTime))
});
return dt;
}
这里面肯定还有好多的毛病,希望各路大神多多指正,我是新手程序员。