网站建设接口开发,企业网站建设方案 word,网站设计专业建站公司,wordpress建站主题这是一个.net下操作数据库(结构数据库)的工具类#xff0c;支持sqlserver、oracle、mysql、postgres、sqlite、access等常见数据库。注意#xff1a;它并不是一个orm工具(常见的orm框架如#xff1a;EF、Dapper等)。2.1 引入DBUtil依赖1. 首先打开vs(推荐vs2019)#xff0c… 这是一个.net下操作数据库(结构数据库)的工具类支持sqlserver、oracle、mysql、postgres、sqlite、access等常见数据库。注意它并不是一个orm工具(常见的orm框架如EF、Dapper等)。2.1 引入DBUtil依赖1. 首先打开vs(推荐vs2019)新建控制台应用程序(.net framework)2. 添加依赖方法1打开工具NuGet包管理器程序包管理器控制台输入Install-Package DBUtil -Version 1.0.03. 添加依赖方法2使用可视化的nuget管理窗口搜索“DBUtil”选择安装即可2.2 准备数据库自行准备吧。2.3 增删改查代码 DBUtil.IDbAccess iDb DBUtil.IDBFactory.CreateIDB(Data Source.;Initial CatalogJACKOA;User IDsa;Passwordxx;,SQLSERVER); Console.WriteLine(iDb.GetFirstColumnString(select Name from SysUser)); Console.WriteLine(iDb.ExecuteSql(updatetest set CaseNoCaseNoe)); Console.WriteLine(iDb.ExecuteSql(update test set CaseNocase,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 CaseNo123)); Console.WriteLine(iDb.DeleteTableRow(test, and id11)); Console.WriteLine(iDb.GetDataSet(select * from sysuser).Tables[0].Rows.Count); 在这个组件设计中所有的数据库操作方法都被集成在了一个对象上IDbAccess。它是一个接口定义了公共的数据库访问方法如增删改查、事务控制等。具体的实现由SqlServerIDbAccess、MySqlIDbAccess、PostgreSqlIDbAccess、OracleIDbAccess、AccessIDbAccess、SQLiteIDbAccess等实现它们分别对应着一种数据库。 在所有的数据库操作之前都必须先创建IDbAccess对象创建的方法如下DBUtil.IDbAccess iDb DBUtil.IDBFactory.CreateIDB(Data Source.;Initial CatalogJACKOA;User IDsa;Passwordxx;,SQLSERVER);你所需的参数有两个1. 数据库的类型字符串 SQLSERVER、ORACLE、MYSQL、POSTGRESQL、ACCESS、SQLITE2. 数据库连接字符串参考以下示例SQLSERVER: Data Source.;Initial CatalogJACKOA;User IDsa;Passwordxx;ORACLE: Data SourceORCLmyvm2;Passwordsys123;User IDsys;DBA PrivilegeSYSDBA;MYSQL: Data Sourcelocalhost;Initial Catalogtest;User IDroot;Passwordxxxx;POSTGRESQL: Serverlocalhost;Port5432;UserIdpostgres;Passwordxxxx;DatabasetestACCESS: ProviderMicrosoft.Jet.OLEDB.4.0;Data SourceG:\work\Multiplan.mdb;ACCESS: ProviderMicrosoft.ACE.OLEDB.12.0;Data SourceC:\Users\Administrator\Desktop\demo.accdb; SQLITE: Data Sourcef:\demo.db;3. sqlite数据库sqlite数据库存储是单个文件存储的所以在访问之前你需要先创建它参照如下代码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 增加数据AddDataDBUtil.IDbAccess iDb DBUtil.IDBFactory.CreateIDB(Data Sourced:\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 删除数据DeleteTableRowiDb.DeleteTableRow(test2, and id1);4.3 更新数据UpdateDataHashtable ht new Hashtable();ht.Add(name, 王五);iDb.UpdateData(test2, ht, and id1);4.4 更新或添加数据UpdateOrAddHashtable ht new Hashtable();ht.Add(id, 1);ht.Add(name, 王五);iDb.UpdateOrAdd(test2, ht, and id1);4.5 查询数据4.5.1 获取第一个值string striDb.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 参数化sql语句iDbAccess的大部分方法都是直接参数化查询的参照如下代码DataTable dt iDb.GetDataTable(string.Format(select * from test2 where name like {0}, iDb.paraPrefix name), new IDbDataParameter[] { iDb.CreatePara(name,%小%) });每个数据库的分页方法不同比如sqlservertop分页、row_number() over()分页、fetch分页mysqllimit分页等等。。。在这个组件中设计为根据指定的查询语句和分页参数生成分页的查询语句参照以下代码DBUtil.IDbAccess iDb DBUtil.IDBFactory.CreateIDB(Data Sourcelocalhost;Initial Catalogimgserver2;User IDroot;Password123456;, 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 Sourcelocalhost;Initial Catalogimgserver2;User IDroot;Password1234567;, MYSQL);DBUtil.Result res iDb.OpenTest();if (res.Success){ Console.WriteLine(连接成功);}else{ Console.WriteLine(连接失败 res.Data);}Console.WriteLine(ok);Console.ReadLine();默认情况下每进行一次数据库的操作都会打开和关闭数据库。在密集的操作下这种方法并不推荐。可以通过IsKeepConnect 属性使数据的链接一直保持iDb.IsKeepConnect true;string filteriDb.GetDateFilter(end, 2016-12-1, 2017-01-01, true, false);bool biDb.JudgeTableOrViewExist(test);bool b2 iDb.JudgeColumnExist(test, id);11.1 说明数据库表的ID的生成是一个常见的问题常见的有表字段设置为自增、设为序列、程序控制ID生成。下面分别说说这三种模式1) 表字段自增在sqlserver中有个致命的缺陷就是一旦遇到数据迁移那么这些ID都将重新生成如果其他的表引用了这个 ID后果可想而知。在mysql中有办法解决这个问题但是这种办法最根本的缺陷在于“不能在数据插入到表之前获取对应的ID”试想一下如果你在插入数据之前还要用到这个ID做其他的工作该怎么办2) 序列法在oracle中可以新建一个序列控制ID的生成sqlserver中好像也开始支持了这种方法其实已经解决了绝大部分问题了但是在每次生成ID之前你还是需要访问一遍数据库如果需要批量生成的时候性能肯定受影响不知道序列支不支持批量生成。3) 程序控制ID生成法这个组件是用的这种方法生成ID的它可以解决上述提到的问题。它的原理是 你在程序中通过指定表名和字段名来获取ID程序中进行判断当前内存中是否缓存了这个ID如果缓存了ID的话就直接自增并返回如果没有缓存ID的话就通过表名和字段名去数据库里面去查找最大的ID然后自增并返回。 优点 1. ID可以随时生成不用非得向表中插入数据。 2. 在批量生成ID时性能很高完全碾压从数据库生成的 3. 可以针对一个表的多个字段进行生成一般用不到 4. 兼容各种数据库你不用再为ID配置各种生成策略 缺点 1. 因为ID的生成缓存到了程序中所以针对一张表必须保证只有一个服务器会进行ID的生成否则会出现重复的ID 注意 有人可能已经注意到问题分布式的ID是怎么生成1个数据库多个服务器这里我提供一个思路但是这个组件中并没有实现针对不同的服务器预先设置ID的前缀比如服务器A的ID 生成从1开始服务器B的ID 生成从100 0000开始这样就不会重叠了。如果担心数据量太大那么你就不能在用int类型的ID了你应该使用字符串唯一编号。这个组件中也实现了唯一编号的生成控制原理和ID一样的都是在程序中缓存只不过使用的时候要配置编号生成的规则...11.2 扩展说明 这个组件默认使用的生成控制器是SimpleIDSNOManager,如果需要扩展(比如使用redis控制生成等)可以自定义实现IDSNOManager,并在应用程序启动时书写IDBFactory. IDSNOManage new 自定义实现();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 自动编号操作 iDb.IDSNOManager.NewSNO(iDb, test, caseno, new ListSerialChunk(){ new SerialChunk(prefix_GWFW,Text[GWFW][4]), new SerialChunk(RiQiCtr,DateTime[yyyyMMdd][8][incycle]), new SerialChunk(SerialNo,SerialNo[1,1,5,,day]) }); Liststring[] li iDb.IDSNOManager.ShowCurrentSNOs(null, null, null); ListSerialChunk li new ListSerialChunk(); 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 ListSerialChunk(){ new SerialChunk(prefix_GWFW,Text[GWFW][4]), new SerialChunk(RiQiCtr,DateTime[yyyyMMdd][8][incycle]), new SerialChunk(SerialNo,SerialNo[1,1,5,,day]) }); Liststring[] li iDb.IDSNOManager.ShowCurrentSNOs(null, null, null); ListSerialChunk li new ListSerialChunk(); 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);
