.NET Core C#系列之XiaoFeng.Data.DataHelper数据库操作_vs 引用system.data.sqlclient

XiaoFeng.Data.DataHelper，当前类库支持MySql,SqlServer,Oledb,SQLite,Oracle,DM等数据库

下面就以SqlServer为例，详细讲解一下当前类库。

第一步，引用 System.Data.SqlClient驱动库

在VS中的解决方案中，依赖项右击管理nuget程序包

在当前界面输入System.Data.SqlClient,如下图

点击安装即可，安装成功后如下图：

第二步，安装XiaoFeng程序包

和第一步一样在管理Nuget程序包里输入 XiaoFeng ，然后安装即可。

第三步，开始写程序

var data = new XiaoFeng.Data.DataHelper(new XiaoFeng.Data.ConnectionConfig
{
ProviderType= XiaoFeng.Data.DbProviderType.SqlServer,
ConnectionString= "server=.;uid=testuser;pwd=123;database=Fay_TestDb;"
});
var dt = data.ExecuteDataTable("select * from F_Tb_Account;");

ConnectionConfig类是一个数据库连接配置类，下边代码就是 配置类的属性，不再赘述。

//
// 摘要:
//     驱动类型
[JsonConverter(typeof(StringEnumConverter))]
[Description("驱动类型")]
public DbProviderType ProviderType { get; set; }
 
//
// 摘要:
//     数据库连接字符串
[Description("数据库连接字符串")]
public string ConnectionString { get; set; }
 
//
// 摘要:
//     是否启用事务处理
[Description("是否启用事务处理")]
public bool IsTransaction { get; set; }
 
//
// 摘要:
//     获取或设置在终止尝试执行命令并生成错误之前的等待时间
[Description("执行超时时间")]
public int CommandTimeOut { get; set; }
 
//
// 摘要:
//     缓存时长 单位为秒 0为永久缓存
[Description("缓存时长 单位为秒 0为永久缓存")]
public int CacheTimeOut { get; set; }
 
//
// 摘要:
//     缓存类型 0不缓存
[Description("缓存类型 Default 默认,No 不缓存,Memory 内存,Disk 磁盘,Redis,Memcache,MongoDB")]
[JsonConverter(typeof(StringEnumConverter))]
public CacheType CacheType { get; set; }
 
//
// 摘要:
//     事务级别
[Description("事务级别 DbNull 空级别,Serializable 串行读,RepeatableRead 可重复读,ReadCommitted 提交读,ReadUncommitted 未提交读,Snapshot 隔离未提交读,Chaos 混乱读,Unspecified 未指定")]
[JsonConverter(typeof(StringEnumConverter))]
public IsolationLevel IsolationLevel { get; set; }
 
 
//
// 摘要:
//     是否启用连接池
[Description("是否启用连接池")]
public bool IsPool { get; set; }
 
//
// 摘要:
//     应用池最大数量
[Description("连接池最大数量")]
public int MaxPool { get; set; }

接下来继续说其它用法

1.直接执行SQL语句

var non1 = data.ExecuteNonQuery("insert into F_Tb_Account(Account,Password) values('jacky','admin');"); non1值，如果non1是-1则表示 执行出错，可以通过data.ErrorMessage拿到最后一次执行出错的错误信息 如果non1是大于等于0则表示执行SQL语句后所执行的行数

2.返回DataTable

var dt = data.ExecuteDataTable("select * from F_Tb_Account;"); dt就是一个datatable

3.直接返回首行首列

var val1 = data.ExecuteScalar("select Acount from F_Tb_Account;"); val1类型是object对象，根据数据库的值不同我们可以自定义转换如：var val2 = (int)val1;也可以用XiaoFeng自带的扩展方法,var val2 = val1.ToCast<int>();

4.直接返回DataReader

var dataReader = data.ExecuteReader("select * from F_Tb_Account;"); dataReader就是DataReader对象

5.直接返回DataSet

var dataSet = data.ExecuteDataSet("select * from F_Tb_Account;select * from F_Tb_Account;"); dataSet就是DataSet对象

6.执行存储过程

var data = data.ExecuteDataTable("proc_name", System.Data.CommandType.StoredProcedure, new System.Data.Common.DbParameter[]
{
data.MakeParam(@"Account","jacky")
});

7.SQL语句带存储参数

var data2 = data.ExecuteDataTable("select * from F_Tb_Account where Account=@Account;", new System.Data.Common.DbParameter[]
{
data.MakeParam(@"@Account","jacky")
});

8.直接转换成对象

var models = data.QueryList<Account>("select * from F_Tb_Account"); var model = data.Query<Account>("select * from F_Tb_Account"); 其实这里面也是在内部调用了 DataTable转List<Model>方法，下边是方法体代码

public T Query<T>(string SQL)
{
    if (SQL.IsNullOrEmpty())
    {
        return default(T);
    }
    
    ValueTypes valueType = typeof(T).GetValueType();
    T result = default(T);
    switch (valueType)
    {
        case ValueTypes.Value:
        case ValueTypes.Enum:
        case ValueTypes.String:
            return ExecuteScalar(SQL).ToCast<T>();
        case ValueTypes.Class:
        case ValueTypes.Struct:
            return ExecuteDataTable(SQL).ToEntity<T>();
        default:
            return result;
    }
}
 
public List<T> QueryList<T>(string SQL)
{
    if (SQL.IsNullOrEmpty())
    {
        return new List<T>();
    }
    return ExecuteDataTable(SQL).ToList<T>();
}

到目前基本功能已经介绍完毕，运行也可以用线程池来操作，自己可以慢慢摸索，不再多多介绍。 下边把整体代码再列一下

var data = new XiaoFeng.Data.DataHelper(new XiaoFeng.Data.ConnectionConfig
{
    ProviderType= XiaoFeng.Data.DbProviderType.SqlServer,
    ConnectionString= "server=.;uid=testuser;pwd=123;database=Fay_TestDb;"
});
var dt = data.ExecuteDataTable("select * from F_Tb_Account;");
var non1 = data.ExecuteNonQuery("insert into F_Tb_Account(Account,Password) values('jacky','admin');");
var val1 = data.ExecuteScalar("select Acount from F_Tb_Account;");
 
var dataReader = data.ExecuteReader("select * from F_Tb_Account;");
 
var dataSet = data.ExecuteDataSet("select * from F_Tb_Account;select * from F_Tb_Account;");
 
var dta = data.ExecuteDataTable("proc_name", System.Data.CommandType.StoredProcedure, new System.Data.Common.DbParameter[]
{
    data.MakeParam(@"@Account","jacky")
});
 
var data2 = data.ExecuteDataTable("select * from F_Tb_Account where Account=@Account;", new System.Data.Common.DbParameter[]
{
    data.MakeParam(@"@Account","jacky")
});
 
var models = data.QueryList<Account>("select * from F_Tb_Account");
 
var model = data.Query<Account>("select top 1 * from F_Tb_Account");

开源地址：XiaoFeng/Threading at master · zhuovi/XiaoFeng · GitHub

语雀地址：作业调度 · 语雀

开源不易，多多支持～