JCoder.Db4Net 2.11.4

JCoder.Db4Net

目录

[TOC]

介绍

1. JCoder = Jackie who a coder.;
2. C#库;
3. Database类库，一款为方便使用数据库的操作类库。

架构说明

.Net框架

引用类库

相关类库

获取方式

1. 版本要求：>=2.3.1
2. 以版本2.3.1为例

使用说明

创建实例

1. MySql

   需要先在项目里引用或加载MySql官方库MySql.Data.dll。

   IDbOperator _operator = new MySqlFactoryOperator()
   {
       ConnectionString = "server=127.0.0.1;database=test;uid=user;pwd=testpassword;Connect Timeout=18000"
   };
   

2. SQLite

   需要先在项目里引用或加载Sqlite官方库System.Data.SQLite.dll。

   IDbOperator _operator = new SQLiteFactoryOperator()
   {
       ConnectionString = "Data Source=.\data\test.db3;"
   };
   

3. Sql Server

   需要先在项目里引用或加载Sql Server官方库System.Data.SqlClient.dll。

   IDbOperator _operator = new SqlServerFactoryOperator()
   {
       ConnectionString = "Server=127.0.0.1;Database=test;Uid = user; Pwd=testpassword;"
   };
   

实例使用

1. CanConnect（是否能够连接数据库）

   // CanConnect（是否能够连接数据库）
   if (_operator.CanConnect()) { return; }
   

2. CreateParameter（创建相应的参数）

   // CreateParameter（创建相应的参数）
   return _operator.CreateParameter( "ID", 123);
   

3. Execute（执行SQL）

   // Execute（执行SQL）
   var _parameters = new List<DbParameter>()
   {
       _operator.CreateParameter("ID","ID123"),
       _operator.CreateParameter("Name","Name123"),
       _operator.CreateParameter("CreateTime",DateTime.Now),
   };
   var _sql = @"insert table1 (ID,Name,CreateTime) values (@ID,@Name,@CreateTime);";
   var _count = _operator.Execute(_sql, _parameters);//直接执行SQL
   //var _count = _operator.Execute(true,_sql, _parameters);// 使用事务执行SQL
   return _count >= 1;
   

4. ExecuteTransaction（使用指定的事务执行指定的SQL）

   // ExecuteTransaction（使用指定的事务执行指定的SQL）
   public void ExecuteTransaction()
   {
       for (int i = 0; i < 3; i++)
       {
           var _key = "Transaction" + i.ToString();
           _operator.StartTransaction(_key);
   
           var _id = i.ToString() + DateTime.Now.ToLongTimeString();
           try
           {
               var _parameters = new List<DbParameter>()
               {
                   _operator.CreateParameter("ID",_id),
                   _operator.CreateParameter("Name","Name123"),
                   _operator.CreateParameter("CreateTime",DateTime.Now),
               };
               var _sql = @"insert table1 (ID,Name,CreateTime) values (@ID,@Name,@CreateTime);";
               var _isSucceed = _operator.ExecuteTransaction(_key, _sql, _parameters);
           }
           catch (Exception ex)
           {
               _operator.RollbackTransaction(_key);
               return;
           }
   
           if (!_operator.FinishTransaction(_key))
           {
               return;
           }
       }
   }
   
   

5. RollbackTransaction（回滚指定的事务）

   // RollbackTransaction（回滚指定的事务）
   public void RollbackTransaction()
   {
       var _key = "Transaction";
       _operator.StartTransaction(_key);
   
       var _id = nameof(RollbackTransaction);
   
       try
       {
           var _parameters = new List<DbParameter>()
           {
               _operator.CreateParameter("ID",_id),
               _operator.CreateParameter("Name","Name123"),
               _operator.CreateParameter("CreateTime",DateTime.Now),
           };
           var _sql = @"insert table1 (ID,Name,CreateTime) values (@ID,@Name,@CreateTime);";
           var _isSucceed = _operator.ExecuteTransaction(_key, _sql, _parameters);
       }
       catch (Exception ex)
       {
           _operator.RollbackTransaction(_key);
           return;
       }
   
       _operator.RollbackTransaction(_key);
   }
   

6. QueryTable（查询数据，并返回DataTable）

   // QueryTable（查询数据，并返回DataTable）
   public DataTable QueryTable()
   {
       var _parameters = new List<DbParameter>()
       {
           _operator.CreateParameter("ID",123),
       };
       var _sql = "select * from table1 where ID=@ID;";
       var _table = _operator.QueryTable(_sql, _parameters);
       return _table;
   }
   

7. QueryReader（查询数据，并返回DbDataReader）

   // QueryReader（查询数据，并返回DbDataReader）
   public QueryReader QueryReader()
   {
       var _parameters = new List<DbParameter>()
       {
           _operator.CreateParameter("ID",123),
       };
       var _sql = "select * from table1 where ID=@ID;";
       var _reader = _operator.QueryReader(_sql, _parameters);
       return _reader;
   }