标签：string 自定义 实体 EDBConnectionType eDBConnectionType dBMapper Linq null public
这里直接列举核心代码，以后整理：
底层引用Dapper。
a1-实体类：
using WebApplication1.DB.Extend;
using WebApplication1.Enum;
namespace WebApplication1.DB.CMS
{
[ClassMapper(EDBConnectionType.SqlServer, "dbo", "TB_UserSendAddressOrder")]
public class TB_UserSendAddressOrder
{
[PropertyMapper]
public int OrderID { get; set; }
[PropertyMapper]
public string AddRessUserName { get; set; }
}
}
View Code
a2-实体表映射类：
using WebApplication1.Enum;
namespace WebApplication1.DB.Extend
{
/// <summary>
/// 数据库表名映射类
/// </summary>
[System.AttributeUsage(System.AttributeTargets.Class, AllowMultiple = true)]
public class ClassMapperAttribute : System.Attribute
{
/// <summary>
/// 数据库类型
/// </summary>
public EDBConnectionType DBConnectionType { get; set; }
/// <summary>
/// 数据库表的架构
/// </summary>
public string SchemaName { get; set; }
/// <summary>
/// 数据库表名称
/// </summary>
public string TableName { get; set; }
/// <summary>
/// 构造
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="schemaName"></param>
/// <param name="tableName"></param>
public ClassMapperAttribute(EDBConnectionType eDBConnectionType, string schemaName = null, string tableName = null)
{
DBConnectionType = eDBConnectionType;
SchemaName = schemaName;
TableName = tableName;
}
}
}
View Code
a3-实体属性映射类：
using System;
namespace WebApplication1.DB.Extend
{
/// <summary>
/// 数据库属性映射类
/// </summary>
[AttributeUsage(AttributeTargets.Field | AttributeTargets.Property, AllowMultiple = false)]
public class PropertyMapperAttribute : Attribute
{
/// <summary>
/// 数据库列名
/// </summary>
public string DBColumnName { get; set; }
/// <summary>
/// 是否是主键列
/// </summary>
public bool IsPrimaryKey { get; set; }
/// <summary>
/// 是否忽略该列
/// </summary>
public bool Ignored { get; set; }
/// <summary>
/// 构造
/// </summary>
public PropertyMapperAttribute() : this(null, false, false)
{
}
/// <summary>
/// 构造
/// </summary>
/// <param name="dbColumnName"></param>
public PropertyMapperAttribute(string dbColumnName) : this(dbColumnName, false, false)
{
}
/// <summary>
/// 构造
/// </summary>
/// <param name="isPrimaryKey"></param>
public PropertyMapperAttribute(bool isPrimaryKey) : this(null, false, isPrimaryKey)
{
}
/// <summary>
/// 构造
/// </summary>
/// <param name="dbColumnName"></param>
/// <param name="isPrimaryKey"></param>
public PropertyMapperAttribute(string dbColumnName, bool isPrimaryKey) : this(dbColumnName, false, isPrimaryKey)
{
}
/// <summary>
/// 构造
/// </summary>
/// <param name="dbColumnName"></param>
/// <param name="ignored"></param>
/// <param name="isPrimaryKey"></param>
public PropertyMapperAttribute(string dbColumnName, bool ignored, bool isPrimaryKey)
{
DBColumnName = dbColumnName;
Ignored = ignored;
IsPrimaryKey = isPrimaryKey;
}
}
}
View Code
a4-数据库类型枚举类：
namespace WebApplication1.Enum
{
/// <summary>
/// DB数据库类型
/// </summary>
public enum EDBConnectionType
{
/// <summary>
/// MySql
/// </summary>
MySql = 0,
/// <summary>
/// SqlServer
/// </summary>
SqlServer = 1,
/// <summary>
/// PostgreSQL
/// </summary>
PostgreSQL = 2,
}
}
View Code
a5-实体映射帮助类：
using System;
using System.Collections.Generic;
using System.Dynamic;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;
using WebApplication1.Enum;
namespace WebApplication1.DB.Extend
{
/// <summary>
/// 数据库映射帮助类
/// </summary>
public class DBMapperHelper
{
/// <summary>
/// 获取映射
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <returns></returns>
public static DBMapperTable GetModelMapper<T>(EDBConnectionType eDBConnectionType)
{
DBMapperTable mapperTable = new DBMapperTable
{
DBPropertyList = new List<DBMapperProperty>(0)
};
Type tType = typeof(T);
IEnumerable<ClassMapperAttribute> classMapperAttributeList = (IEnumerable<ClassMapperAttribute>)tType.GetCustomAttributes(typeof(ClassMapperAttribute));
ClassMapperAttribute classMapperAttribute = classMapperAttributeList.ToList().FirstOrDefault(m => m.DBConnectionType == eDBConnectionType);
if (classMapperAttribute != null)
{
mapperTable.SchemaName = classMapperAttribute.SchemaName;
mapperTable.TableName = classMapperAttribute.TableName;
if (string.IsNullOrEmpty(mapperTable.TableName))
{
mapperTable.TableName = tType.Name;
}
}
List<PropertyInfo> tPropertyInfoList = tType.GetProperties().ToList();
PropertyMapperAttribute propertyMapAttribute = null;
foreach (var tPropertyInfo in tPropertyInfoList)
{
propertyMapAttribute = (PropertyMapperAttribute)tPropertyInfo.GetCustomAttribute(typeof(PropertyMapperAttribute));
//属性映射特性&&不忽略
if (propertyMapAttribute != null && propertyMapAttribute.Ignored == false)
{
if (string.IsNullOrEmpty(propertyMapAttribute.DBColumnName))
{
propertyMapAttribute.DBColumnName = tPropertyInfo.Name;
}
mapperTable.DBPropertyList.Add(new DBMapperProperty
{
DBColumnName = propertyMapAttribute.DBColumnName,
IsPrimaryKey = propertyMapAttribute.IsPrimaryKey,
PropertyInfo = tPropertyInfo
});
}
}
return mapperTable;
}
/// <summary>
/// 获取插入语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tArray"></param>
/// <returns></returns>
public static string GetInsertSql<T>(EDBConnectionType eDBConnectionType, params T[] tArray)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> columnSqlList = dBMapper.DBColumnList;
List<string> valuesSqlList = new List<string>(tArray.Length);
foreach (var tModel in tArray)
{
List<string> tValueList = new List<string>(dBMapper.DBPropertyList.Count);
foreach (DBMapperProperty dbMapperProperty in dBMapper.DBPropertyList)
{
string paramValue = FormatDBValue(dbMapperProperty.PropertyInfo.GetValue(tModel));
tValueList.Add(paramValue);
}
valuesSqlList.Add($"({string.Join(',', tValueList)})");
}
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string insertSql = $"insert into {tableSql}({string.Join(',', columnSqlList)}) values {string.Join(',', valuesSqlList)};";
return insertSql;
}
/// <summary>
/// 获取更新语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public static string GetUpdateSql<T>(EDBConnectionType eDBConnectionType, T tModel)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> updatePropertySQLList = new List<string>(dBMapper.DBPropertyList.Count);
foreach (DBMapperProperty dbMapperProperty in dBMapper.DBPropertyList)
{
if (dbMapperProperty.IsPrimaryKey == false)
{
updatePropertySQLList.Add($"{dbMapperProperty.DBColumnName}={FormatDBValue(dbMapperProperty.PropertyInfo.GetValue(tModel))}");
}
}
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string updateSQL = $"update {tableSql} set {string.Join(',', updatePropertySQLList)} where {primaryProperty.DBColumnName}={FormatDBValue(primaryProperty.PropertyInfo.GetValue(tModel))}";
return updateSQL;
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="primaryPropertyValue"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
string updateSQL = null;
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
if (primaryProperty != null)
{
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
updateSQL = $"delete from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryPropertyValue)}";
}
return updateSQL ?? "";
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, T tModel)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string updateSQL = $"delete from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryProperty.PropertyInfo.GetValue(tModel))}";
return updateSQL;
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="whereExpression"></param>
/// <param name="paramObj"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> whereExpression, out Dictionary<string, object> paramObj)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string sql = $"delete from {tableSql}";
if (whereExpression != null)
{
WherePart wherePart = new WhereBuilder().ToSql(whereExpression);
sql += $"where {wherePart.Sql}";
ExpandoObject param = new ExpandoObject();
foreach (var item in wherePart.Parameters)
{
((IDictionary<string, object>)param).Add(item.Key, item.Value);
}
paramObj = wherePart.Parameters;
}
else
{
paramObj = null;
}
return sql;
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="primaryPropertyValue"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
string sql = null;
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
if (primaryProperty != null)
{
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
sql = $"select * from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryPropertyValue)}";
}
return sql ?? "";
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="sort"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, Sort<T> sort)
{
string sql = GetSelectSql(eDBConnectionType, null, sort, out Dictionary<string, object> paramObj);
return sql;
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="whereExpression"></param>
/// <param name="sort"></param>
/// <param name="paramObj"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> whereExpression, Sort<T> sort, out Dictionary<string, object> paramObj)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> columnSqlList = dBMapper.DBColumnList;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string sql = $"select {string.Join(',', columnSqlList)} from {tableSql}";
if (whereExpression != null)
{
WherePart wherePart = new WhereBuilder().ToSql(whereExpression);
sql += $" where {wherePart.Sql}";
ExpandoObject param = new ExpandoObject();
foreach (var item in wherePart.Parameters)
{
((IDictionary<string, object>)param).Add(item.Key, item.Value);
}
paramObj = wherePart.Parameters;
}
else
{
paramObj = null;
}
if (sort != null)
{
string sortSql = sort.ToSql();
if (!string.IsNullOrWhiteSpace(sortSql))
{
sql += $" order by {sortSql}";
}
}
return sql;
}
/// <summary>
/// 格式化数据库值
/// </summary>
/// <param name="paramValue"></param>
/// <returns></returns>
private static string FormatDBValue(object paramValue)
{
string param = paramValue?.ToString();
if (string.IsNullOrEmpty(param))
{
param = "NULL";
}
else
{
if (param.Contains("'"))
{
param = paramValue.ToString().Replace("'", "''");
}
if (paramValue is string)
{
param = $"'{param}'";
}
else if (paramValue is DateTime || paramValue is DateTime?)
{
param = "'" + Convert.ToDateTime(param).ToString("yyyy-MM-dd HH:mm:ss.fff") + "'";
}
}
return param;
}
/// <summary>
/// 数据库映射表
/// </summary>
public class DBMapperTable
{
/// <summary>
/// 数据库表的架构
/// </summary>
public string SchemaName { get; set; }
/// <summary>
/// 数据库表名称
/// </summary>
public string TableName { get; set; }
/// <summary>
/// 数据库列列表
/// </summary>
public List<DBMapperProperty> DBPropertyList { get; set; }
/// <summary>
/// 数据库主键Key
/// </summary>
public string DBPrimaryKey
{
get
{
return DBPropertyList.FirstOrDefault(m => m.IsPrimaryKey)?.DBColumnName ?? "";
}
}
/// <summary>
/// 数据库主键属性
/// </summary>
public DBMapperProperty DBPrimaryProperty
{
get
{
return DBPropertyList.FirstOrDefault(m => m.IsPrimaryKey);
}
}
/// <summary>
/// 数据库列名列表
/// </summary>
public List<string> DBColumnList
{
get
{
return DBPropertyList.Select(m => m.DBColumnName).ToList();
}
}
}
/// <summary>
/// 数据库映射属性
/// </summary>
public class DBMapperProperty
{
/// <summary>
/// 数据库列名
/// </summary>
public string DBColumnName { get; set; }
/// <summary>
/// 是否是主键列
/// </summary>
public bool IsPrimaryKey { get; set; }
/// <summary>
/// 属性信息
/// </summary>
public PropertyInfo PropertyInfo { get; set; }
}
}
}
View Code
b1-仓储类基类：
using Dapper;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Linq;
using System.Linq.Expressions;
using System.Threading.Tasks;
using WebApplication1.DB.Extend;
using WebApplication1.Enum;
using WebApplication1.Helper;
using WebApplication1.Model;
namespace WebApplication1.DB.Base
{
/// <summary>
/// 仓储基类
/// </summary>
public class BaseRepository
{
/// <summary>
/// 配置执行超时时间120（秒）
/// </summary>
private int commandTimeout = 120;
private ConfigHelper _configHelper { get; set; }
/// <summary>
/// 构造
/// </summary>
/// <param name="configHelper"></param>
public BaseRepository(ConfigHelper configHelper)
{
this._configHelper = configHelper;
}
/// <summary>
/// 获取连接串
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <returns></returns>
private string getDbConnectionStr(EDBConnectionType eDBConnectionType)
{
Dictionary<EDBConnectionType, ConfigDBConnection> connectionDic = this._configHelper.GetDBConnectionDic();
ConfigDBConnection configDBConnection = connectionDic[eDBConnectionType];
return configDBConnection.ConnectionStr;
}
/// <summary>
/// 获取连接串
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <returns></returns>
private IDbConnection getDbConnection(EDBConnectionType eDBConnectionType)
{
IDbConnection dbConnection = null;
Dictionary<EDBConnectionType, ConfigDBConnection> connectionDic = this._configHelper.GetDBConnectionDic();
ConfigDBConnection configDBConnection = connectionDic[eDBConnectionType];
if (eDBConnectionType == EDBConnectionType.SqlServer)
{
dbConnection = SqlClientFactory.Instance.CreateConnection();
}
else if (eDBConnectionType == EDBConnectionType.MySql)
{
dbConnection = MySqlConnector.MySqlConnectorFactory.Instance.CreateConnection();
}
else if (eDBConnectionType == EDBConnectionType.PostgreSQL)
{
dbConnection = Npgsql.NpgsqlFactory.Instance.CreateConnection();
}
dbConnection.ConnectionString = configDBConnection.ConnectionStr;
return dbConnection;
}
/// <summary>
/// 批量数据插入
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tList"></param>
/// <returns></returns>
public async Task<int> InsertListAsync<T>(EDBConnectionType eDBConnectionType, List<T> tList)
{
int result = 0;
if (tList != null && tList.Count > 0)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string insertSql = DBMapperHelper.GetInsertSql(eDBConnectionType, tList.ToArray());
result = await dbConnection.ExecuteAsync(insertSql, commandTimeout: this.commandTimeout);
}
return result;
}
/// <summary>
/// 高级批量插入
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="insertList"></param>
public async Task BulkCopyAsync<T>(EDBConnectionType eDBConnectionType, List<T> insertList)
{
if (insertList != null && insertList.Count > 0)
{
//数据量大于100使用SqlBulkCopy，小于100使用批量sql插入
if (insertList.Count > 100)
{
DataTable table = new DataTable();
DBMapperHelper.DBMapperTable mapperTable = DBMapperHelper.GetModelMapper<T>(eDBConnectionType);
string conn = this.getDbConnectionStr(eDBConnectionType);
// read the table structure from the database
string tableName = $"{mapperTable.SchemaName}.{mapperTable.TableName}";
DbDataAdapter dbDataAdapter = null;
if (eDBConnectionType == EDBConnectionType.SqlServer)
{
dbDataAdapter = new SqlDataAdapter($"SELECT TOP 0 * FROM {tableName}", conn);
}
else if (eDBConnectionType == EDBConnectionType.MySql)
{
dbDataAdapter = new MySqlConnector.MySqlDataAdapter($"SELECT * FROM {tableName} LIMIT 0", conn);
}
else if (eDBConnectionType == EDBConnectionType.PostgreSQL)
{
dbDataAdapter = new Npgsql.NpgsqlDataAdapter($"SELECT TOP 0 * FROM {tableName}", conn);
}
using (dbDataAdapter)
{
dbDataAdapter.Fill(table);
}
int count = insertList.Count;
for (var i = 0; i < count; i++)
{
var row = table.NewRow();
foreach (DBMapperHelper.DBMapperProperty item in mapperTable.DBPropertyList)
{
row[item.DBColumnName] = item.PropertyInfo.GetValue(insertList[i]) ?? DBNull.Value;
}
table.Rows.Add(row);
}
using (IDbConnection dbConnection = this.getDbConnection(eDBConnectionType))
{
if (dbConnection.State == ConnectionState.Closed)
{
dbConnection.Open();
}
if (eDBConnectionType == EDBConnectionType.SqlServer)
{
using (var bulk = new SqlBulkCopy(dbConnection as SqlConnection))
{
//设置超时时间=1000秒
bulk.BulkCopyTimeout = 1000;
bulk.DestinationTableName = tableName;
await bulk.WriteToServerAsync(table);
}
}
else if (eDBConnectionType == EDBConnectionType.MySql)
{
var bulk = new MySqlConnector.MySqlBulkCopy(dbConnection as MySqlConnector.MySqlConnection);
//设置超时时间=1000秒
bulk.BulkCopyTimeout = 1000;
bulk.DestinationTableName = tableName;
await bulk.WriteToServerAsync(table);
}
else if (eDBConnectionType == EDBConnectionType.PostgreSQL)
{
//NpgSql暂未找到合适的大批量插入方法
await this.InsertListAsync(eDBConnectionType, insertList);
}
};
}
else
{
await this.InsertListAsync(eDBConnectionType, insertList);
}
}
}
/// <summary>
/// 查出多条记录的实体泛型集合
/// </summary>
/// <typeparam name="T">泛型T</typeparam>
/// <returns></returns>
public async Task<List<T>> SelectAsync<T>(EDBConnectionType eDBConnectionType, Sort<T> sort = null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string sql = DBMapperHelper.GetSelectSql<T>(eDBConnectionType, sort);
List<T> tList = (await dbConnection.QueryAsync<T>(sql, null, commandTimeout: this.commandTimeout)).ToList();
return tList ?? new List<T>(0);
}
/// <summary>
/// 查出单条数据
/// </summary>
/// <typeparam name="T">泛型T</typeparam>
/// <param name="eDBConnectionType">数据库类型</param>
/// <param name="primaryPropertyValue">主键值</param>
/// <returns></returns>
public async Task<T> FirstAsync<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
T t = default(T);
if (primaryPropertyValue != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
Dictionary<string, object> paramDic = null;
string sql = DBMapperHelper.GetSelectSql<T>(eDBConnectionType, primaryPropertyValue);
t = await dbConnection.QueryFirstOrDefaultAsync<T>(sql, paramDic, commandTimeout: commandTimeout);
}
return t;
}
/// <summary>
/// 查出单条数据
/// </summary>
/// <typeparam name="T">泛型T</typeparam>
/// <param name="eDBConnectionType">数据库类型</param>
/// <param name="expression">查询表达式</param>
/// <returns></returns>
public async Task<T> FirstAsync<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> expression)
{
T t = default(T);
if (expression != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
Dictionary<string, object> paramDic = null;
string sql = DBMapperHelper.GetSelectSql<T>(eDBConnectionType, expression, null, out paramDic);
t = await dbConnection.QueryFirstOrDefaultAsync<T>(sql, paramDic, commandTimeout: commandTimeout);
}
return t;
}
/// <summary>
/// 查出多条记录的实体泛型集合
/// </summary>
/// <typeparam name="T">泛型T</typeparam>
/// <returns></returns>
public async Task<List<T>> SelectAsync<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> expression, Sort<T> sort = null)
{
List<T> tList = null;
if (expression != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
Dictionary<string, object> paramDic = null;
string sql = DBMapperHelper.GetSelectSql<T>(eDBConnectionType, expression, sort, out paramDic);
tList = (await dbConnection.QueryAsync<T>(sql, paramDic, commandTimeout: this.commandTimeout)).ToList();
}
return tList ?? new List<T>(0);
}
/// <summary>
/// Query
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="sql"></param>
/// <returns></returns>
public async Task<List<T>> QueryAsync<T>(EDBConnectionType eDBConnectionType, string sql)
{
List<T> tList = null;
if (!string.IsNullOrEmpty(sql))
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
tList = (await dbConnection.QueryAsync<T>(sql, commandTimeout: this.commandTimeout)).ToList();
}
return tList ?? new List<T>(0);
}
/// <summary>
/// Execute
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public async Task<int> ExecuteAsync(EDBConnectionType eDBConnectionType, string sql, object param)
{
int executeNum = 0;
if (!string.IsNullOrWhiteSpace(sql))
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
executeNum = await dbConnection.ExecuteAsync(sql, param, commandTimeout: this.commandTimeout);
}
return executeNum;
}
/// <summary>
/// ExecuteScalar
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public async Task<object> ExecuteScalar(EDBConnectionType eDBConnectionType, string sql, object param)
{
object firstData = null;
if (!string.IsNullOrWhiteSpace(sql))
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
firstData = await dbConnection.ExecuteScalarAsync(sql, param, commandTimeout: this.commandTimeout);
}
return firstData;
}
/// <summary>
/// 更新对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public async Task<int> Update<T>(EDBConnectionType eDBConnectionType, T tModel)
{
int result = 0;
if (tModel != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string updateSQL = DBMapperHelper.GetUpdateSql(eDBConnectionType, tModel);
result = await dbConnection.ExecuteAsync(updateSQL, commandTimeout: this.commandTimeout);
}
return result;
}
/// <summary>
/// 删除对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="primaryPropertyValue"></param>
/// <returns></returns>
public async Task<int> Delete<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
int result = 0;
if (primaryPropertyValue != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string sql = DBMapperHelper.GetDeleteSql(eDBConnectionType, primaryPropertyValue);
if (sql.IsNotNullOrEmpty())
{
result = await dbConnection.ExecuteAsync(sql, commandTimeout: this.commandTimeout);
}
}
return result;
}
/// <summary>
/// 删除对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public async Task<int> Delete<T>(EDBConnectionType eDBConnectionType, T tModel)
{
int result = 0;
if (tModel != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string sql = DBMapperHelper.GetDeleteSql(eDBConnectionType, tModel);
if (sql.IsNotNullOrEmpty())
{
result = await dbConnection.ExecuteAsync(sql, commandTimeout: this.commandTimeout);
}
}
return result;
}
/// <summary>
/// 删除对象
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="expression"></param>
/// <returns></returns>
public async Task<int> Delete<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> expression)
{
int result = 0;
if (expression != null)
{
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
string sql = DBMapperHelper.GetDeleteSql(eDBConnectionType, expression);
result = await dbConnection.ExecuteAsync(sql, commandTimeout: this.commandTimeout);
}
return result;
}
/// <summary>
/// Count
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="where"></param>
/// <param name="param"></param>
/// <returns></returns>
public async Task<int> Count<T>(EDBConnectionType eDBConnectionType, string where, object param)
{
DBMapperHelper.DBMapperTable dBMapper = DBMapperHelper.GetModelMapper<T>(eDBConnectionType);
string whereSql = "";
if (!string.IsNullOrWhiteSpace(where))
{
whereSql = $"where {where}";
}
string countSql = $"select count(1) from {dBMapper.SchemaName}.{dBMapper.TableName} {whereSql}";
int count = Convert.ToInt32(await this.ExecuteScalar(eDBConnectionType, countSql, param));
return count;
}
/// <summary>
/// GetList
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="pageIndex"></param>
/// <param name="pageSize"></param>
/// <param name="where"></param>
/// <param name="sortFiled"></param>
/// <param name="param"></param>
/// <returns></returns>
public async Task<(List<T>, int)> GetList<T>(EDBConnectionType eDBConnectionType, int pageIndex, int pageSize, string where, string sortFiled, object param = null)
{
if (pageIndex <= 0 || pageSize <= 0)
{
throw new ArgumentException("pageIndex、pageSize参数错误");
}
DBMapperHelper.DBMapperTable dBMapper = DBMapperHelper.GetModelMapper<T>(eDBConnectionType);
List<string> fieldList = dBMapper.DBColumnList;
int begin = pageSize * (pageIndex - 1);
string sql = string.Empty;
string tableName = dBMapper.TableName;
string orderSql = string.Empty;
int recordCount = await this.Count<T>(eDBConnectionType, where, param);
if (!string.IsNullOrWhiteSpace(sortFiled))
{
orderSql = "ORDER BY " + sortFiled;
}
if (!string.IsNullOrWhiteSpace(where))
{
where = " WHERE " + where;
}
else
{
where = " WHERE 1=1";
}
//传统查询
//sql = $"SELECT {string.Join(',', fieldList)} FROM {tableName} {where} {orderSql} LIMIT {begin},{pageSize}";
//高性能查询
//优化查询性能、利用单列(优先主键)查询速度，快速过滤不需要的数据
string primaryKey = dBMapper.DBPrimaryKey;
if (primaryKey.IsNullOrEmpty())
{
primaryKey = dBMapper.DBColumnList.FirstOrDefault();
}
if (eDBConnectionType == EDBConnectionType.MySql)
{
sql = $"SELECT {string.Join(',', fieldList)} FROM {tableName} {where} {orderSql} LIMIT {begin},{pageSize}";
}
else if (eDBConnectionType == EDBConnectionType.SqlServer)
{
sql = $@"SELECT TOP({pageSize}) {string.Join(',', fieldList)} FROM {tableName} {where} AND {primaryKey} NOT IN (SELECT TOP({begin}) {primaryKey} FROM {tableName} {where} {orderSql}) {orderSql} ";
}
IDbConnection dbConnection = this.getDbConnection(eDBConnectionType);
List<T> list = (await dbConnection.QueryAsync<T>(sql, param)).ToList();
return (list, recordCount);
}
}
/// <summary>
/// 仓储基类
/// </summary>
public class BaseRepository<T, TKey> : BaseRepository
{
/// <summary>
/// 构造
/// </summary>
/// <param name="configHelper"></param>
public BaseRepository(ConfigHelper configHelper) : base(configHelper)
{
}
/// <summary>
/// 查出多条记录的实体泛型集合
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="sort"></param>
/// <returns></returns>
public Task<List<T>> Select(EDBConnectionType eDBConnectionType, Sort<T> sort = null)
{
return base.SelectAsync(eDBConnectionType, sort);
}
/// <summary>
/// 查出单条数据
/// </summary>
/// <param name="eDBConnectionType">数据库类型</param>
/// <param name="primaryPropertyValue">主键值</param>
/// <returns></returns>
public async Task<T> First(EDBConnectionType eDBConnectionType, TKey primaryPropertyValue)
{
return await base.FirstAsync<T>(eDBConnectionType, primaryPropertyValue);
}
/// <summary>
/// 查出单条数据
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="expression"></param>
/// <returns></returns>
public Task<T> First(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> expression)
{
return base.FirstAsync(eDBConnectionType, expression);
}
/// <summary>
/// 查出多条记录的实体泛型集合
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="expression"></param>
/// <param name="sort"></param>
/// <returns></returns>
public Task<List<T>> Select(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> expression, Sort<T> sort = null)
{
return base.SelectAsync(eDBConnectionType, expression, sort);
}
/// <summary>
/// 插入实体记录
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="entity"></param>
/// <returns></returns>
public async Task<int> Insert(EDBConnectionType eDBConnectionType, T entity)
{
return await base.InsertListAsync(eDBConnectionType, new List<T> { entity });
}
/// <summary>
/// 批量数据插入
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="tList"></param>
/// <returns></returns>
public Task<int> InsertList(EDBConnectionType eDBConnectionType, List<T> tList)
{
return base.InsertListAsync(eDBConnectionType, tList);
}
/// <summary>
/// 更新实体记录
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="entity"></param>
/// <returns></returns>
public async Task<int> Update(EDBConnectionType eDBConnectionType, T entity)
{
return await base.Update(eDBConnectionType, entity);
}
/// <summary>
/// 删除指定键的记录
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="ID"></param>
/// <returns></returns>
public async Task<int> Delete(EDBConnectionType eDBConnectionType, TKey ID)
{
return await base.Delete(eDBConnectionType, ID);
}
/// <summary>
/// 删除实体记录
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="entity"></param>
/// <returns></returns>
public async Task<int> Delete(EDBConnectionType eDBConnectionType, T entity)
{
return await base.Delete(eDBConnectionType, entity);
}
/// <summary>
/// 删除所有符合特定表达式的数据
/// </summary>
/// <param name="eDBConnectionType"></param>
/// <param name="whereExpress"></param>
/// <returns></returns>
public async Task<int> Delete(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> whereExpress)
{
return await base.Delete(eDBConnectionType, whereExpress);
}
}
}
View Code
b2-仓储类：
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WebApplication1.DB.Base;
using WebApplication1.DB.CMS;
using WebApplication1.Enum;
using WebApplication1.Helper;
namespace WebApplication1.DB.Repository
{
public class TB_UserSendAddressOrderRepository : BaseRepository<TB_UserSendAddressOrder, string>
{
public TB_UserSendAddressOrderRepository(ConfigHelper configHelper) : base(configHelper)
{
}
public async Task<List<TB_UserSendAddressOrder>> GetModelByOrderID(int siteID, int orderID)
{
List<TB_UserSendAddressOrder> dataList = await base.Select(EDBConnectionType.SqlServer, m => m.SiteID == siteID && m.OrderID == orderID);
return dataList;
}
}
}
View Code
b3-数据库映射帮助类：
using System;
using System.Collections.Generic;
using System.Dynamic;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;
using WebApplication1.Enum;
namespace WebApplication1.DB.Extend
{
/// <summary>
/// 数据库映射帮助类
/// </summary>
public class DBMapperHelper
{
/// <summary>
/// 获取映射
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <returns></returns>
public static DBMapperTable GetModelMapper<T>(EDBConnectionType eDBConnectionType)
{
DBMapperTable mapperTable = new DBMapperTable
{
DBPropertyList = new List<DBMapperProperty>(0)
};
Type tType = typeof(T);
IEnumerable<ClassMapperAttribute> classMapperAttributeList = (IEnumerable<ClassMapperAttribute>)tType.GetCustomAttributes(typeof(ClassMapperAttribute));
ClassMapperAttribute classMapperAttribute = classMapperAttributeList.ToList().FirstOrDefault(m => m.DBConnectionType == eDBConnectionType);
if (classMapperAttribute != null)
{
mapperTable.SchemaName = classMapperAttribute.SchemaName;
mapperTable.TableName = classMapperAttribute.TableName;
if (string.IsNullOrEmpty(mapperTable.TableName))
{
mapperTable.TableName = tType.Name;
}
}
List<PropertyInfo> tPropertyInfoList = tType.GetProperties().ToList();
PropertyMapperAttribute propertyMapAttribute = null;
foreach (var tPropertyInfo in tPropertyInfoList)
{
propertyMapAttribute = (PropertyMapperAttribute)tPropertyInfo.GetCustomAttribute(typeof(PropertyMapperAttribute));
//属性映射特性&&不忽略
if (propertyMapAttribute != null && propertyMapAttribute.Ignored == false)
{
if (string.IsNullOrEmpty(propertyMapAttribute.DBColumnName))
{
propertyMapAttribute.DBColumnName = tPropertyInfo.Name;
}
mapperTable.DBPropertyList.Add(new DBMapperProperty
{
DBColumnName = propertyMapAttribute.DBColumnName,
IsPrimaryKey = propertyMapAttribute.IsPrimaryKey,
PropertyInfo = tPropertyInfo
});
}
}
return mapperTable;
}
/// <summary>
/// 获取插入语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tArray"></param>
/// <returns></returns>
public static string GetInsertSql<T>(EDBConnectionType eDBConnectionType, params T[] tArray)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> columnSqlList = dBMapper.DBColumnList;
List<string> valuesSqlList = new List<string>(tArray.Length);
foreach (var tModel in tArray)
{
List<string> tValueList = new List<string>(dBMapper.DBPropertyList.Count);
foreach (DBMapperProperty dbMapperProperty in dBMapper.DBPropertyList)
{
string paramValue = FormatDBValue(dbMapperProperty.PropertyInfo.GetValue(tModel));
tValueList.Add(paramValue);
}
valuesSqlList.Add($"({string.Join(',', tValueList)})");
}
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string insertSql = $"insert into {tableSql}({string.Join(',', columnSqlList)}) values {string.Join(',', valuesSqlList)};";
return insertSql;
}
/// <summary>
/// 获取更新语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public static string GetUpdateSql<T>(EDBConnectionType eDBConnectionType, T tModel)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> updatePropertySQLList = new List<string>(dBMapper.DBPropertyList.Count);
foreach (DBMapperProperty dbMapperProperty in dBMapper.DBPropertyList)
{
if (dbMapperProperty.IsPrimaryKey == false)
{
updatePropertySQLList.Add($"{dbMapperProperty.DBColumnName}={FormatDBValue(dbMapperProperty.PropertyInfo.GetValue(tModel))}");
}
}
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string updateSQL = $"update {tableSql} set {string.Join(',', updatePropertySQLList)} where {primaryProperty.DBColumnName}={FormatDBValue(primaryProperty.PropertyInfo.GetValue(tModel))}";
return updateSQL;
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="primaryPropertyValue"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
string updateSQL = null;
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
if (primaryProperty != null)
{
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
updateSQL = $"delete from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryPropertyValue)}";
}
return updateSQL ?? "";
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="tModel"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, T tModel)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string updateSQL = $"delete from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryProperty.PropertyInfo.GetValue(tModel))}";
return updateSQL;
}
/// <summary>
/// 获取删除语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="whereExpression"></param>
/// <param name="paramObj"></param>
/// <returns></returns>
public static string GetDeleteSql<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> whereExpression, out Dictionary<string, object> paramObj)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string sql = $"delete from {tableSql}";
if (whereExpression != null)
{
WherePart wherePart = new WhereBuilder().ToSql(whereExpression);
sql += $"where {wherePart.Sql}";
ExpandoObject param = new ExpandoObject();
foreach (var item in wherePart.Parameters)
{
((IDictionary<string, object>)param).Add(item.Key, item.Value);
}
paramObj = wherePart.Parameters;
}
else
{
paramObj = null;
}
return sql;
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="primaryPropertyValue"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, object primaryPropertyValue)
{
string sql = null;
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
DBMapperProperty primaryProperty = dBMapper.DBPrimaryProperty;
if (primaryProperty != null)
{
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
sql = $"select * from {tableSql} where {primaryProperty.DBColumnName}={FormatDBValue(primaryPropertyValue)}";
}
return sql ?? "";
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="sort"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, Sort<T> sort)
{
string sql = GetSelectSql(eDBConnectionType, null, sort, out Dictionary<string, object> paramObj);
return sql;
}
/// <summary>
/// 获取查询语句
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="eDBConnectionType"></param>
/// <param name="whereExpression"></param>
/// <param name="sort"></param>
/// <param name="paramObj"></param>
/// <returns></returns>
public static string GetSelectSql<T>(EDBConnectionType eDBConnectionType, Expression<Func<T, bool>> whereExpression, Sort<T> sort, out Dictionary<string, object> paramObj)
{
DBMapperTable dBMapper = GetModelMapper<T>(eDBConnectionType);
List<string> columnSqlList = dBMapper.DBColumnList;
string tableSql = (dBMapper.SchemaName.IsNotNullOrEmpty() ? dBMapper.SchemaName + "." : "") + dBMapper.TableName;
string sql = $"select {string.Join(',', columnSqlList)} from {tableSql}";
if (whereExpression != null)
{
WherePart wherePart = new WhereBuilder().ToSql(whereExpression);
sql += $" where {wherePart.Sql}";
ExpandoObject param = new ExpandoObject();
foreach (var item in wherePart.Parameters)
{
((IDictionary<string, object>)param).Add(item.Key, item.Value);
}
paramObj = wherePart.Parameters;
}
else
{
paramObj = null;
}
if (sort != null)
{
string sortSql = sort.ToSql();
if (!string.IsNullOrWhiteSpace(sortSql))
{
sql += $" order by {sortSql}";
}
}
return sql;
}
/// <summary>
/// 格式化数据库值
/// </summary>
/// <param name="paramValue"></param>
/// <returns></returns>
private static string FormatDBValue(object paramValue)
{
string param = paramValue?.ToString();
if (string.IsNullOrEmpty(param))
{
param = "NULL";
}
else
{
if (param.Contains("'"))
{
param = paramValue.ToString().Replace("'", "''");
}
if (paramValue is string)
{
param = $"'{param}'";
}
else if (paramValue is DateTime || paramValue is DateTime?)
{
param = "'" + Convert.ToDateTime(param).ToString("yyyy-MM-dd HH:mm:ss.fff") + "'";
}
}
return param;
}
/// <summary>
/// 数据库映射表
/// </summary>
public class DBMapperTable
{
/// <summary>
/// 数据库表的架构
/// </summary>
public string SchemaName { get; set; }
/// <summary>
/// 数据库表名称
/// </summary>
public string TableName { get; set; }
/// <summary>
/// 数据库列列表
/// </summary>
public List<DBMapperProperty> DBPropertyList { get; set; }
/// <summary>
/// 数据库主键Key
/// </summary>
public string DBPrimaryKey
{
get
{
return DBPropertyList.FirstOrDefault(m => m.IsPrimaryKey)?.DBColumnName ?? "";
}
}
/// <summary>
/// 数据库主键属性
/// </summary>
public DBMapperProperty DBPrimaryProperty
{
get
{
return DBPropertyList.FirstOrDefault(m => m.IsPrimaryKey);
}
}
/// <summary>
/// 数据库列名列表
/// </summary>
public List<string> DBColumnList
{
get
{
return DBPropertyList.Select(m => m.DBColumnName).ToList();
}
}
}
/// <summary>
/// 数据库映射属性
/// </summary>
public class DBMapperProperty
{
/// <summary>
/// 数据库列名
/// </summary>
public string DBColumnName { get; set; }
/// <summary>
/// 是否是主键列
/// </summary>
public bool IsPrimaryKey { get; set; }
/// <summary>
/// 属性信息
/// </summary>
public PropertyInfo PropertyInfo { get; set; }
}
}
}
View Code
b4-数据库连接配置帮助类：
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.Configuration;
using System;
using System.Collections.Generic;
using WebApplication1.Enum;
using WebApplication1.Model;
namespace WebApplication1.Helper
{
/// <summary>
/// 配置帮助类
/// </summary>
public class ConfigHelper
{
private IConfiguration _Configuration = null;
private IMemoryCache _MemoryCache = null;
/// <summary>
/// 构造
/// </summary>
/// <param name="configuration"></param>
/// <param name="memoryCache"></param>
public ConfigHelper(IConfiguration configuration, IMemoryCache memoryCache)
{
this._Configuration = configuration;
this._MemoryCache = memoryCache;
}
private Dictionary<EDBConnectionType, ConfigDBConnection> _DBConnectionDic = null;
/// <summary>
/// 获取所有数据库连接字符串
/// </summary>
/// <returns></returns>
public Dictionary<EDBConnectionType, ConfigDBConnection> GetDBConnectionDic()
{
if (this._DBConnectionDic == null || this._DBConnectionDic.Count == 0)
{
this._DBConnectionDic = this._MemoryCache.GetOrCreate("DBConnection", cacheEntry =>
{
cacheEntry.SetAbsoluteExpiration(DateTimeOffset.Now.AddDays(1));
Dictionary<EDBConnectionType, ConfigDBConnection> connectionDic = new Dictionary<EDBConnectionType, ConfigDBConnection>(0);
IConfigurationSection dbSection = this._Configuration.GetSection("DBConnection");
string providerName = null;
EDBConnectionType connectionType = default;
foreach (IConfigurationSection item in dbSection.GetChildren())
{
providerName = item.GetValue<string>("ProviderName");
if (providerName.Equals(EDBConnectionType.SqlServer.ToString(), StringComparison.OrdinalIgnoreCase))
{
connectionType = EDBConnectionType.SqlServer;
}
else if (providerName.Equals(EDBConnectionType.MySql.ToString(), StringComparison.OrdinalIgnoreCase))
{
connectionType = EDBConnectionType.MySql;
}
else if (providerName.Equals(EDBConnectionType.PostgreSQL.ToString(), StringComparison.OrdinalIgnoreCase))
{
connectionType = EDBConnectionType.PostgreSQL;
}
connectionDic.Add(connectionType, new ConfigDBConnection
{
ProviderName = providerName,
ConnectionStr = item.GetValue<string>("ConnectionStr")
});
}
cacheEntry.SetValue(connectionDic);
return connectionDic;
});
}
return this._DBConnectionDic ?? new Dictionary<EDBConnectionType, ConfigDBConnection>(0);
}
}
}
View Code
b5-.net core-appsetting.json数据库配置示例：
{
"DBConnection": [
{
"ProviderName": "SqlServer",
"ConnectionStr": "数据库连接串"
}
]
}
View Code
b6-Linq To SQL帮助类：
请参考我的文章：使用LINQ生成Where的SQL语句
使用示例：可查看仓储类。
标签：string,自定义,实体,EDBConnectionType,eDBConnectionType,dBMapper,Linq,null,public 来源： https://www.cnblogs.com/lxhbky/p/16607114.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。