(文章目录)
前言
DeveloperSharp是一个研发中大型项目必备的系统平台。也是一个低代码平台。
它主要包括了如下一些功能：
- 基于Sql语句、存储过程、事务、分页的数据库操作。并几乎支持市面上所有种类的数据库。
- 图片操作。裁剪、缩放、加水印。
- http请求调用（Post与Get）
- 高效分页
- Web服务/WebApi的负载均衡
- 数据库的负载均衡，以及读写分离
- CORS跨域访问
- UUID全球通用唯一识别码
- MQ消息队列（请另行使用DeveloperSharp.RabbitMQ包）
- Redis缓存（请另行使用DeveloperSharp.Redis包）
- “异种数据库”的负载均衡
- 其他相关功能
一、DeveloperSharp的使用
1.安装包
DeveloperSharp
2.初始化数据库连接
using DeveloperSharp.Framework.QueryEngine;
DatabaseInfo DIF;
DIF.DatabaseType = DatabaseType.SQLServer; //设置数据库类型
DIF.ConnectionString = "Server=localhost;Database=PSIDBase;Uid=sa;Pwd=1";
IDataAccess IDA = DataAccessFactory.Create(DIF);
通过对DatabaseType属性的设定，提供了对所有种类数据库的支持（包括：MySql、Oracle、PostgreSQL、SqlServer、Sqlite、Firebird、达梦、以及人大金仓KingbaseES、神舟通用, 南大通用, 翰高, Access、等）
3.查询数据
1、普通查询
using DeveloperSharp.Framework.QueryEngine;
using System.Data;
DatabaseInfo DIF;
DIF.DatabaseType = DatabaseType.SQLServer; //设置数据库类型
DIF.ConnectionString = "Server=localhost;Database=PSIDBase;Uid=sa;Pwd=1";
IDataAccess IDA = DataAccessFactory.Create(DIF);
//查询多数据
var Students1 = IDA.SqlExecute<UserInfos>("select * from UserInfos");
//查询多数据（带参数）
var Students2 = IDA.SqlExecute<UserInfos>("select * from UserInfos where UserId>@IdMin and UserName like @LikeName", new { IdMin = 5, LikeName = "%lyc%" });
//另一种写法1
var IdMin = IDA.CreateParameterInput("IdMin", DbType.Int32, 4);
var LikeName = IDA.CreateParameterInput("LikeName", DbType.String, 50, "%lyc%");
var Students3 = IDA.SqlExecute<UserInfos>("select * from UserInfos where UserId>@IdMin and UserName like @LikeName", LikeName, IdMin);
//另一种写法2
var Students4 = IDA.SqlExecute<UserInfos>("select * from UserInfos").Where(t => t.UserId > 2 && t.UserName.Contains("lyc"));
//选出单数据
var OneStudent = Students2.FirstOrDefault();
public class UserInfos
{
public int UserId { get; set; }
public string UserName { get; set; }
public int Age { get; set; }
public string UserPwd { get; set; }
public int UserState { get; set; }
}
2、分页查询
//--------------------------------------------分页------------------------------------------------
var Page1 = Students1.PagePartition(3, 1);
//一气呵成的写法
var Page3 = IDA.SqlExecute<UserInfos>("select * from UserInfos").PagePartition(3, 2);
4.增/删/改
try
{
//开启事务
IDA.TransactionBegin();
//修改数据（多语句）
int affectedRows1 = IDA.SqlExecute("insert into UserInfos(UserName,Age)values('ww','96');update UserInfos set Age=100 where Id=1006");
//修改数据（带参数）
int affectedRows2 = IDA.SqlExecute("insert into UserInfos(UserName,Age)values(@N,@A)", new { N = "愚公", A = 200 });
//另一种写法
var NewAge = IDA.CreateParameterInput("NewAge", DbType.Int32, 200);
var NewName = IDA.CreateParameterInput("NewName", DbType.String, 50, "愚公");
int affectedRows3 = IDA.SqlExecute("insert into UserInfos(UserName,Age)values(@NewName,@NewAge)", NewName, NewAge);
//完成事务
IDA.TransactionCommit();
}
catch
{
//回滚事务
IDA.TransactionRollBack();
}
5.输出参数
var op1 = IDA.CreateParameterOutput("TotalCount", DbType.Int32);//此项为输出参数
var op2 = IDA.CreateParameterOutput("MyName", DbType.String, 50);//此项为输出参数
//以下sql语句混杂了多个“输入”与“输出”参数，注意看
IDA.SqlExecute("insert into Friend(Birth,Name,height)values(@B,@N,@h);" +
"select @TotalCount=count(*) from Friend;" +
"select @MyName=Name from Friend where Id=@Id",
new { N = "愚公", B = "1999-02-28 12:03:45", h = 11.023, Id = 2 },
op1, op2);
int tc = Convert.ToInt32(op1.Value);
string mn = op2.Value.ToString();
6.存储过程
1、创建存储过程
CREATE PROCEDURE Test5
@B as datetime,
@N as nvarchar(50),
@h as float,
@TotalCount as int output,
@MyName as nvarchar(50) output,
@Id as int
AS
BEGIN
insert into Friend(Birth,Name,height)values(@B,@N,@h);
select @TotalCount=count(*) from Friend;
select @MyName=Name from Friend where Id=@Id;
return @TotalCount+100;
END
2、调用存储过程
var op1 = IDA.CreateParameterOutput("TotalCount", DbType.Int32);//输出参数
var op2 = IDA.CreateParameterOutput("MyName", DbType.String, 50);//输出参数
var op3 = IDA.CreateParameterReturn();//返回参数
IDA.SpExecute("Test5", new { N = "愚公", B = "1999-02-28 12:03:45", h = 11.023, Id = 2 }, op1, op2, op3);
int tc = Convert.ToInt32(op1.Value);
string mn = op2.Value.ToString();
int ret = Convert.ToInt32(op3.Value);
二、DeveloperSharp的参数说明
1.SqlExecute<T>
- 声明：IEnumerable<T> SqlExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
- 用途：执行Sql语句(Select类)
- 参数： （1）string cmdText -- Sql语句 （2）params IDataParameter[] Params -- 参数组 返回：IEnumerable<T> -- 多数据结果集
2.SqlExecute<T>
- 声明：IEnumerable<T> SqlExecute<T>(string cmdText, object InputParams,params IDataParameter[] Params) where T : class, new()
- 用途：执行Sql语句(Select类)
- 参数： （1）string cmdText -- Sql语句 （2）object InputParams -- 输入参数对象 （3）params IDataParameter[] Params -- 参数组 返回：IEnumerable<T> -- 多数据结果集
3.SqlExecute
- 声明：int SqlExecute(string cmdText, params IDataParameter[] Params)
- 用途：执行Sql语句(Insert/Update/Delete类)
- 参数： （1）string cmdText -- Sql语句 （2）params IDataParameter[] Params -- 参数组 返回：int -- 受影响的行数
4.SqlExecute
- 声明：int SqlExecute(string cmdText, object InputParams, params IDataParameter[] Params)
- 用途：执行Sql语句(Insert/Update/Delete类)
- 参数： （1）string cmdText -- Sql语句 （2）object InputParams -- 输入参数对象 （3）params IDataParameter[] Params -- 参数组 返回：int -- 受影响的行数
5.SpExecute<T>
- 声明：IEnumerable<T> SpExecute<T>(string cmdText, params IDataParameter[] Params) where T : class, new()
- 用途：执行Sp存储过程(Select类)
- 参数： （1）string cmdText -- Sp存储过程名 （2）params IDataParameter[] Params -- 参数组 返回：IEnumerable<T> -- 多数据结果集
6.SpExecute<T>
- 声明：IEnumerable<T> SpExecute<T>(string cmdText, object InputParams, params IDataParameter[] Params) where T : class, new()
- 用途：执行Sp存储过程(Select类)
- 参数： （1）string cmdText -- Sp存储过程名 （2）object InputParams -- 输入参数对象 （3）params IDataParameter[] Params -- 参数组 返回：IEnumerable<T> -- 多数据结果集
7.SpExecute
- 声明：int SpExecute(string cmdText, params IDataParameter[] Params)
- 用途：执行Sp存储过程(Insert/Update/Delete类)
- 参数： （1）string cmdText -- Sp存储过程名 （2）params IDataParameter[] Params -- 参数组 返回：int -- 受影响的行数
8.SpExecute
- 声明：int SpExecute(string cmdText, object InputParams, params IDataParameter[] Params)
- 用途：执行Sp存储过程(Insert/Update/Delete类)
- 参数： （1）string cmdText -- Sp存储过程名 （2）object InputParams -- 输入参数对象 （3）params IDataParameter[] Params -- 参数组 返回：int -- 受影响的行数