mysql批量插入数据的基类

自己设计的一个mysql数据库批量添加数据的基类。用于批量向mysql数据库添加数据，子类实现起来很简单，自测性能也还不错。

1、基类实现-BatchAddBase

using System.Collections.Generic;
using System.Text;

namespace MysqlBatchAdd
{
public abstract class BatchAddBase<T> where T : class, new()
{
/// <summary>
/// 插入语句的头部
/// </summary>
protected abstract string InsertHead { get; }

/// <summary>
/// 出入语句的执行体
/// </summary>
protected List<string> InsertBodyList { get; set; } = new List<string>();
/// <summary>
/// 缓存的sql语句长度
/// </summary>
public int SqlCacheLengh { get; set; } = 1000 * 10;

/// <summary>
/// 批量添加的方法
/// </summary>
/// <param name="m"></param>
public abstract void BatchAdd(T m);

/// <summary>
/// 执行添加
/// </summary>
public virtual void ExecuteBatchAdd()
{
StringBuilder sqlCache = new StringBuilder();

foreach (string insertBody in InsertBodyList)
{
sqlCache.Append(insertBody + ",");

if (sqlCache.Length >= SqlCacheLengh)
{
sqlCache.Remove(sqlCache.Length - 1, 1);
MySqlHelper.ExecuteNonQuery(this.InsertHead + sqlCache.ToString());
sqlCache.Clear();
}
}

if (sqlCache.Length > 0)
{
sqlCache.Remove(sqlCache.Length - 1, 1);
MySqlHelper.ExecuteNonQuery(this.InsertHead + sqlCache.ToString());
sqlCache.Clear();
}
}
/// <summary>
/// 清楚缓存
/// </summary>
public void ClearInsertBody()
{
this.InsertBodyList.Clear();
}
}
}

2、一个简单的子类实现-PersonAddHelper

namespace MysqlBatchAdd
{
public class PersonAddHelper : BatchAddBase<Person>
{
protected override string InsertHead
{
get
{
return @"insert into person(
name) values ";
}
}

public override void BatchAdd(Person m)
{
this.InsertBodyList.Add($@" (
'{m.name}')");
}
}
}

3、控制台项目，使用示例

static void Main(string[] args)
{
PersonAddHelper personAddHelper = new PersonAddHelper();

Stopwatch watch = new Stopwatch();

watch.Start();

int amount = 100000;

for (int i = 1; i <= amount; i++)
{
personAddHelper.BatchAdd(new Person() { name = i + "号" });
}

personAddHelper.ExecuteBatchAdd();

watch.Stop();

Console.WriteLine($"成功插入 {amount} 条数据，用时：{watch.ElapsedMilliseconds} ms");

Console.ReadKey();
}

4、源码示例地址：http://files.cnblogs.com/files/renjing/MysqlBatchAdd.rar