這是一個(gè).net下操作數(shù)據(jù)庫(kù)(結(jié)構(gòu)數(shù)據(jù)庫(kù))的工具類，支持sqlserver、oracle、mysql、postgres、sqlite、access等常見(jiàn)數(shù)據(jù)庫(kù)。

注意：它并不是一個(gè)orm工具(常見(jiàn)的orm框架如：EF、Dapper等)。

2.1 引入DBUtil依賴

1. 首先打開(kāi)vs(推薦vs2019)，新建控制臺(tái)應(yīng)用程序(.net framework)

2. 添加依賴方法1：打開(kāi)工具>NuGet包管理器>程序包管理器控制臺(tái)，輸入：

Install-Package DBUtil -Version 1.0.0

3. 添加依賴方法2：使用可視化的nuget管理窗口搜索“DBUtil”，選擇安裝即可！

2.2 準(zhǔn)備數(shù)據(jù)庫(kù)

自行準(zhǔn)備吧。

2.3 增刪改查代碼

DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB("Data Source=.;Initial Catalog=JACKOA;User ID=sa;Password=xx;","SQLSERVER"); Console.WriteLine(iDb.GetFirstColumnString("select Name from SysUser")); Console.WriteLine(iDb.ExecuteSql("updatetest set CaseNo=CaseNo+'e'")); Console.WriteLine(iDb.ExecuteSql("update test set CaseNo=@case",newIDataParameter[] { iDb.CreatePara("case","123") })); Hashtable ht = newSystem.Collections.Hashtable(); ht.Add("CaseNo", "456"); ht.Add("Name", "ji"); Console.WriteLine(iDb.AddData("test",ht)); Hashtable ht2 = newSystem.Collections.Hashtable(); ht2.Add("Name", "jiko"); Console.WriteLine(iDb.UpdateData("test",ht2," and CaseNo='123'")); Console.WriteLine(iDb.DeleteTableRow("test"," and id=11")); Console.WriteLine(iDb.GetDataSet("select * from sysuser").Tables[0].Rows.Count);

? ? 在這個(gè)組件設(shè)計(jì)中，所有的數(shù)據(jù)庫(kù)操作方法都被集成在了一個(gè)對(duì)象上：IDbAccess。它是一個(gè)接口，定義了公共的數(shù)據(jù)庫(kù)訪問(wèn)方法，如：增刪改查、事務(wù)控制等。具體的實(shí)現(xiàn)由SqlServerIDbAccess、MySqlIDbAccess、PostgreSqlIDbAccess、OracleIDbAccess、AccessIDbAccess、SQLiteIDbAccess等實(shí)現(xiàn)，它們分別對(duì)應(yīng)著一種數(shù)據(jù)庫(kù)。

? ? 在所有的數(shù)據(jù)庫(kù)操作之前，都必須先創(chuàng)建IDbAccess對(duì)象，創(chuàng)建的方法如下：

DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB("Data Source=.;Initial Catalog=JACKOA;User ID=sa;Password=xx;","SQLSERVER");

你所需的參數(shù)有兩個(gè)：

1. 數(shù)據(jù)庫(kù)的類型字符串

? ? SQLSERVER、ORACLE、MYSQL、POSTGRESQL、ACCESS、SQLITE

2. 數(shù)據(jù)庫(kù)連接字符串

參考以下示例：

SQLSERVER: Data Source=.;Initial Catalog=JACKOA;User ID=sa;Password=xx;
ORACLE: Data Source=ORCLmyvm2;Password=sys123;User ID=sys;DBA Privilege=SYSDBA;
MYSQL: Data Source=localhost;Initial Catalog=test;User ID=root;Password=xxxx;
POSTGRESQL: Server=localhost;Port=5432;UserId=postgres;Password=xxxx;Database=test
ACCESS: Provider=Microsoft.Jet.OLEDB.4.0;Data Source=G:\work\Multiplan.mdb;
ACCESS: Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\Users\Administrator\Desktop\demo.accdb;
?SQLITE: Data Source=f:\demo.db;

3. sqlite數(shù)據(jù)庫(kù)

sqlite數(shù)據(jù)庫(kù)存儲(chǔ)是單個(gè)文件存儲(chǔ)的，所以在訪問(wèn)之前你需要先創(chuàng)建它，參照如下代碼：

DBUtil.IDBFactory.CreateSQLiteDB("d:\\demo.db");string str = DBUtil.IDBFactory.GetSQLiteConnectionString("d:\\demo.db");DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB(str, "SQLITE");iDb.ExecuteSql(@"create table test(id int primary key,name varchar(50));insert into test values(1,'張三');insert into test values(2,'李四');");string name = iDb.GetFirstColumnString("select name from test");Console.WriteLine(name);

四、增刪改查方法

4.1 增加數(shù)據(jù)（AddData）

DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB(@"Data Source=d:\demo.db;", "SQLITE");iDb.ExecuteSql(@"create table test2(id int primary key,name varchar(50),createtime timestamp,largefield blob)");Hashtable ht = new Hashtable(); ht.Add("id", 1);ht.Add("name", "李四"); ht.Add("createtime", DateTime.Now);ht.Add("largefield", System.Text.Encoding.UTF8.GetBytes("我的密碼是：xxxxxx"));iDb.AddData("test2", ht);Console.WriteLine(iDb.GetFirstColumnString("select name from test2"));Console.WriteLine(iDb.GetFirstColumnString("select createtime from test2")); Console.WriteLine(System.Text.Encoding.UTF8.GetString(iDb.GetFirstColumn("select largefield from test2") as byte[]));Console.WriteLine("ok");Console.ReadLine();

4.2 刪除數(shù)據(jù)（DeleteTableRow）

iDb.DeleteTableRow("test2", "and id=1");

4.3 更新數(shù)據(jù)（UpdateData）

Hashtable ht = new Hashtable();ht.Add("name", "王五");iDb.UpdateData("test2", ht, "and id=1");

4.4 更新或添加數(shù)據(jù)（UpdateOrAdd）

Hashtable ht = new Hashtable();ht.Add("id", 1);ht.Add("name", "王五");iDb.UpdateOrAdd("test2", ht, "and id=1");

4.5 查詢數(shù)據(jù)

4.5.1 獲取第一個(gè)值

string str=iDb.GetFirstColumnString("select name from test2");object obj= iDb.GetFirstColumnString("select largefield from test2");

4.5.2 獲取表

DataTable dt = iDb.GetDataTable("select * from test2");DataSet ds = iDb.GetDataSet("select * from test2;select * from test2;");

4.6 參數(shù)化sql語(yǔ)句

iDbAccess的大部分方法都是直接參數(shù)化查詢的，參照如下代碼：

DataTable dt = iDb.GetDataTable(string.Format("select * from test2 where name like {0}", iDb.paraPrefix + "name"), new IDbDataParameter[] { iDb.CreatePara("name","%小%") });

每個(gè)數(shù)據(jù)庫(kù)的分頁(yè)方法不同，比如：

sqlserver：top分頁(yè)、row_number() over()分頁(yè)、fetch分頁(yè)

mysql：limit分頁(yè)

等等。。。

在這個(gè)組件中設(shè)計(jì)為：根據(jù)指定的查詢語(yǔ)句和分頁(yè)參數(shù)生成分頁(yè)的查詢語(yǔ)句，參照以下代碼：

DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB(@"Data Source=localhost;Initial Catalog=imgserver2;User ID=root;Password=123456;", "MYSQL");string selectSql = "select * from test2";string orderSql = "order by id desc";int pageSize = 10;int pageIndex = 1;string sqlFinal = iDb.GetSqlForPageSize(selectSql, orderSql, pageSize, pageIndex);Console.WriteLine(sqlFinal);iDb.BeginTrans();IDbTransaction tran= iDb.tran;iDb.Commit();iDb.Rollback();bool b = iDb.IsTran;DBUtil.IDbAccess iDb = DBUtil.IDBFactory.CreateIDB(@"Data Source=localhost;Initial Catalog=imgserver2;User ID=root;Password=1234567;", "MYSQL");DBUtil.Result res = iDb.OpenTest();if (res.Success){ Console.WriteLine("連接成功！");}else{ Console.WriteLine("連接失敗：" + res.Data);}Console.WriteLine("ok");Console.ReadLine();

默認(rèn)情況下，每進(jìn)行一次數(shù)據(jù)庫(kù)的操作都會(huì)打開(kāi)和關(guān)閉數(shù)據(jù)庫(kù)。在密集的操作下這種方法并不推薦。

可以通過(guò)IsKeepConnect 屬性使數(shù)據(jù)的鏈接一直保持

iDb.IsKeepConnect = true;string filter=iDb.GetDateFilter("end", "2016-12-1", "2017-01-01", true, false);bool b=iDb.JudgeTableOrViewExist("test");bool b2 = iDb.JudgeColumnExist("test", "id");

11.1 說(shuō)明

數(shù)據(jù)庫(kù)表的ID的生成是一個(gè)常見(jiàn)的問(wèn)題，常見(jiàn)的有表字段設(shè)置為自增、設(shè)為序列、程序控制ID生成。下面分別說(shuō)說(shuō)這三種模式：

1)? 表字段自增：在sqlserver中有個(gè)致命的缺陷就是一旦遇到數(shù)據(jù)遷移，那么這些ID都將重新生成，如果其他的表引用了這個(gè) ID，后果可想而知。在mysql中有辦法解決這個(gè)問(wèn)題，但是這種辦法最根本的缺陷在于：“不能在數(shù)據(jù)插入到表之前獲取對(duì)應(yīng)的ID”，試想一下：如果你在插入數(shù)據(jù)之前還要用到這個(gè)ID做其他的工作該怎么辦？

2) 序列法：在oracle中可以新建一個(gè)序列控制ID的生成（sqlserver中好像也開(kāi)始支持了），這種方法其實(shí)已經(jīng)解決了絕大部分問(wèn)題了，但是在每次生成ID之前你還是需要訪問(wèn)一遍數(shù)據(jù)庫(kù)，如果需要批量生成的時(shí)候性能肯定受影響（不知道序列支不支持批量生成）。

3) 程序控制ID生成法：這個(gè)組件是用的這種方法生成ID的，它可以解決上述提到的問(wèn)題。它的原理是：

? ? 你在程序中通過(guò)指定表名和字段名來(lái)獲取ID，程序中進(jìn)行判斷當(dāng)前內(nèi)存中是否緩存了這個(gè)ID，如果緩存了ID的話就直接自增并返回，如果沒(méi)有緩存ID的話就通過(guò)表名和字段名去數(shù)據(jù)庫(kù)里面去查找最大的ID，然后自增并返回。

? ??優(yōu)點(diǎn)：

? ? ? ? 1. ID可以隨時(shí)生成，不用非得向表中插入數(shù)據(jù)。

? ? ? ? 2. 在批量生成ID時(shí)，性能很高（完全碾壓從數(shù)據(jù)庫(kù)生成的）

? ? ? ? 3. 可以針對(duì)一個(gè)表的多個(gè)字段進(jìn)行生成（一般用不到）

? ? ? ? 4. 兼容各種數(shù)據(jù)庫(kù)，你不用再為ID配置各種生成策略

? ??缺點(diǎn)：

? ? ? ? 1. 因?yàn)镮D的生成緩存到了程序中，所以針對(duì)一張表必須保證只有一個(gè)服務(wù)器會(huì)進(jìn)行ID的生成，否則會(huì)出現(xiàn)重復(fù)的ID

? ??注意：

? ? ? ? 有人可能已經(jīng)注意到問(wèn)題，分布式的ID是怎么生成（1個(gè)數(shù)據(jù)庫(kù)，多個(gè)服務(wù)器）？這里我提供一個(gè)思路，但是這個(gè)組件中并沒(méi)有實(shí)現(xiàn)：針對(duì)不同的服務(wù)器預(yù)先設(shè)置ID的前綴，比如服務(wù)器A的ID 生成從1開(kāi)始，服務(wù)器B的ID 生成從100 0000開(kāi)始，這樣就不會(huì)重疊了。如果擔(dān)心數(shù)據(jù)量太大，那么你就不能在用int類型的ID了，你應(yīng)該使用字符串唯一編號(hào)。這個(gè)組件中也實(shí)現(xiàn)了唯一編號(hào)的生成控制，原理和ID一樣的都是在程序中緩存，只不過(guò)使用的時(shí)候要配置編號(hào)生成的規(guī)則...

11.2 擴(kuò)展說(shuō)明

? ? 這個(gè)組件默認(rèn)使用的生成控制器是SimpleIDSNOManager,如果需要擴(kuò)展(比如使用redis控制生成等)可以自定義實(shí)現(xiàn)IDSNOManager,并在應(yīng)用程序啟動(dòng)時(shí)書寫：IDBFactory. IDSNOManage= new 自定義實(shí)現(xiàn)();

11.3 使用方法

? 11.3.1 ID操作

int id = iDb.IDSNOManager.NewID(iDb, "test", "id"); int id2 = iDb.IDSNOManager.NewIDForce(iDb, "test", "id"); iDb.IDSNOManager.ResetID("test", "id", 1); iDb.IDSNOManager.ShowCurrentIDs(null,null);

? 11.3.2 自動(dòng)編號(hào)操作

? ?? ? ? iDb.IDSNOManager.NewSNO(iDb, "test", "caseno", new List<SerialChunk>(){? ? ? ? ? ?new SerialChunk("prefix_GWFW","Text[GWFW][4]"),? ? ? ? ? ?new SerialChunk("RiQiCtr","DateTime[yyyyMMdd][8][incycle]"),? ? ? ? ? ?new SerialChunk("SerialNo","SerialNo[1,1,5,,day]")? ? ? });? ?? ? List<string[]> li = iDb.IDSNOManager.ShowCurrentSNOs(null, null, null);? ?? ? List<SerialChunk> li = new List<SerialChunk>();? ? li.Add(new SerialChunk(“prefix_GWFW”,null));? ? li.Add(new SerialChunk(“RiQiCtr”,null));? ? li.Add(new SerialChunk(“SerialNo”,null));? ? iDb.IDSNOManager.ResetSNO(tableName, colName, li, null);? ? iDb.IDSNOManager.NewSNO(iDb, "test", "caseno", new List<SerialChunk>(){? ? new SerialChunk("prefix_GWFW","Text[GWFW][4]"),? ? new SerialChunk("RiQiCtr","DateTime[yyyyMMdd][8][incycle]"),? ? new SerialChunk("SerialNo","SerialNo[1,1,5,,day]")? ? });? ?? ? List<string[]> li = iDb.IDSNOManager.ShowCurrentSNOs(null, null, null);? ?? ? List<SerialChunk> li = new List<SerialChunk>();? ? li.Add(new SerialChunk(“prefix_GWFW”,null));? ? li.Add(new SerialChunk(“RiQiCtr”,null));? ? li.Add(new SerialChunk(“SerialNo”,null));? ? iDb.IDSNOManager.ResetSNO(tableName, colName, li, null);

總結(jié)

以上是生活随笔為你收集整理的一个通用数据库操作组件DBUtil(c#)、支持SqlServer、Oracle、Mysql、postgres、SQLITE的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。