703 lines
29 KiB
C#
703 lines
29 KiB
C#
using Furion.DependencyInjection;
|
|
using Furion.FriendlyException;
|
|
using Microsoft.Extensions.Caching.Memory;
|
|
using Microsoft.Extensions.Localization;
|
|
using MySql.Data.MySqlClient;
|
|
using Newtonsoft.Json.Linq;
|
|
using RoadFlow.Utility;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.Common;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace RoadFlow.Data
|
|
{
|
|
public class DbConnection:RoadFlowRepository<RoadFlow.Model.rf_dbconnection>,IDbConnection, ITransient
|
|
{
|
|
/// <summary>
|
|
/// 添加一个连接
|
|
/// </summary>
|
|
/// <param name="dbConnection">连接实体</param>
|
|
/// <returns></returns>
|
|
public override int Add(Model.rf_dbconnection dbConnection)
|
|
{
|
|
ClearCache();
|
|
dbConnection.ConnString = dbConnection.ConnString.DESEncrypt();
|
|
return db.Insertable(dbConnection).ExecuteCommand();
|
|
}
|
|
/// <summary>
|
|
/// 更新连接
|
|
/// </summary>
|
|
/// <param name="dictionary">连接实体</param>
|
|
public override int Update(Model.rf_dbconnection dbConnection, bool clearCache = true)
|
|
{
|
|
if(clearCache)
|
|
ClearCache();
|
|
dbConnection.ConnString = dbConnection.ConnString.DESEncrypt();
|
|
return db.Updateable(dbConnection).ExecuteCommand();
|
|
}
|
|
/// <summary>
|
|
/// 得到所有连接
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public override List<Model.rf_dbconnection> GetAll()
|
|
{
|
|
return _memoryCache.GetOrCreate(CACHEKEY, v =>
|
|
{
|
|
var dbConnections = db.Queryable<Model.rf_dbconnection>().OrderBy(p => p.Sort).ToList();
|
|
foreach (var dbConn in dbConnections)
|
|
{
|
|
dbConn.ConnString = dbConn.ConnString.DESDecrypt();
|
|
}
|
|
return dbConnections;
|
|
});
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 得到一个表所有字段
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <param name="tableName"></param>
|
|
/// <returns></returns>
|
|
public List<Model.TableField> GetTableFields(string id, string tableName)
|
|
{
|
|
var conn = GetOneById(id);
|
|
if (null == conn)
|
|
{
|
|
return new List<Model.TableField>();
|
|
}
|
|
return GetTableFields(conn, tableName);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个表所有字段
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <param name="tableName"></param>
|
|
/// <returns></returns>
|
|
public List<Model.TableField> GetTableFields(Model.rf_dbconnection conn, string tableName)
|
|
{
|
|
List<Model.TableField> tableFields = new List<Model.TableField>();
|
|
string dbName = string.Empty;
|
|
if (conn.ConnType.EqualsIgnoreCase("mysql"))
|
|
{
|
|
string[] connStringArray = conn.ConnString.Split(';');
|
|
foreach (string connString in connStringArray)
|
|
{
|
|
string[] connArray = connString.Split('=');
|
|
if (connArray.Length > 1 && (connArray[0].Trim().Equals("database") || connArray[0].Trim().Equals("db") || connArray[0].Trim().Equals("Initial Catalog")))
|
|
{
|
|
dbName = connArray[1].Trim();
|
|
}
|
|
}
|
|
}
|
|
var dt = this.GetTableFields(conn, tableName, dbName);
|
|
foreach (DataRow dr in dt.Rows)
|
|
{
|
|
Model.TableField tableField = new Model.TableField()
|
|
{
|
|
FieldName = dr["f_name"].ToString().Trim(),
|
|
Type = dr["t_name"].ToString(),
|
|
Size = dr["length"].ToString().ToInt(),
|
|
IsNull = "1".Equals(dr["is_null"].ToString()),
|
|
IsDefault = dr["cdefault"].ToString().ToInt(0) != 0,
|
|
IsIdentity = dr["isidentity"].ToString().ToInt() == 1,
|
|
DefaultValue = dr["defaultvalue"].ToString(),
|
|
Comment = dr["comments"].ToString()
|
|
};
|
|
tableFields.Add(tableField);
|
|
}
|
|
return tableFields;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个表所有字段
|
|
/// </summary>
|
|
/// <param name="dbConnection"></param>
|
|
/// <param name="table">表名</param>
|
|
/// <param name="dbName">数据库名(MYSQL时需要,防止同一个连接中不同的数据库中有相同的表名的情况。其它数据库为空)</param>
|
|
/// <returns>返回datatable 列:f_name,t_name,length,is_null,cdefault,isidentity,defaultvalue,comments</returns>
|
|
public DataTable GetTableFields(Model.rf_dbconnection dbConnection, string table, string dbName)
|
|
{
|
|
using var conn = dbConnection.GetConn(db);
|
|
string sql = GetTableFieldsSql(dbConnection, table, dbName);
|
|
return conn.Ado.GetDataTable(sql);
|
|
}
|
|
|
|
|
|
private string GetTableFieldsSql(Model.rf_dbconnection dbConnection, string tableName, string dbName)
|
|
{
|
|
using (var conn = db.GetConnection(dbConnection.Id))
|
|
{
|
|
switch (dbConnection.DbType)
|
|
{
|
|
case SqlSugar.DbType.MySql:
|
|
return "SELECT COLUMN_NAME f_name,DATA_TYPE t_name, CHARACTER_MAXIMUM_LENGTH length " +
|
|
",CASE IS_NULLABLE WHEN 'NO' THEN 0 WHEN 'YES' THEN 1 END is_null,COLUMN_DEFAULT cdefault,0 isidentity,COLUMN_DEFAULT defaultvalue,COLUMN_COMMENT comments FROM " +
|
|
"information_schema.TABLES a " +
|
|
"LEFT JOIN information_schema.COLUMNS b ON a.table_name = b.TABLE_NAME " +
|
|
"WHERE a.TABLE_NAME='" + tableName + "'"
|
|
+ (dbName.IsNullOrWhiteSpace() ? "" : " AND a.TABLE_SCHEMA='" + dbName + "' AND b.TABLE_SCHEMA='" + dbName + "'")
|
|
+ " ORDER BY b.ordinal_position";
|
|
case SqlSugar.DbType.SqlServer:
|
|
return string.Format("select a.name as f_name,b.name as t_name,a.prec as [length],a.isnullable as is_null,a.cdefault as cdefault," +
|
|
"COLUMNPROPERTY(OBJECT_ID('{0}'),a.name,'IsIdentity') as isidentity," +
|
|
"(select top 1 text from sysobjects d inner join syscolumns e on e.id=d.id inner join syscomments f on f.id=e.cdefault " +
|
|
"where d.name='{0}' and e.name=a.name) as defaultvalue,cast([value] as varchar(500)) as comments " +
|
|
"from sys.syscolumns a left join sys.types b on b.user_type_id=a.xtype left join sys.extended_properties x " +
|
|
"on x.major_id=OBJECT_ID('{0}') and x.minor_id=a.colid " +
|
|
"where OBJECT_ID('{0}')=id order by a.colid", tableName);
|
|
case SqlSugar.DbType.Oracle:
|
|
return string.Format("SELECT user_tab_columns.COLUMN_NAME as f_name," +
|
|
"user_tab_columns.DATA_TYPE as t_name," +
|
|
"user_tab_columns.CHAR_LENGTH AS length," +
|
|
"CASE user_tab_columns.NULLABLE WHEN 'Y' THEN 1 WHEN 'N' THEN 0 END AS is_null," +
|
|
"user_tab_columns.DATA_DEFAULT AS cdefault," +
|
|
"0 as isidentity,user_tab_columns.DATA_DEFAULT AS defaultvalue,user_col_comments.comments FROM user_tab_columns,user_col_comments " +
|
|
"WHERE user_tab_columns.COLUMN_NAME=user_col_comments.COLUMN_NAME " +
|
|
"and user_tab_columns.TABLE_NAME=user_col_comments.TABLE_NAME " +
|
|
"and UPPER(user_tab_columns.TABLE_NAME)=UPPER('{0}') " +
|
|
"and UPPER(user_col_comments.TABLE_NAME)=UPPER('{0}') " +
|
|
"ORDER BY user_tab_columns.COLUMN_ID", tableName);
|
|
case SqlSugar.DbType.PostgreSQL:
|
|
return "select column_name as f_name,udt_name as t_name,character_maximum_length as length,case is_nullable when 'NO' then 0 when 'YES' then 1 end as is_null,column_default as cdefault,case is_identity when 'NO' then 0 when 'YES' then 1 end as isidentity,column_default as defaultvalue,'' as comments from information_schema.columns where table_name='" + tableName.ToLower() + "' order by ordinal_position";
|
|
case SqlSugar.DbType.Dm:
|
|
case SqlSugar.DbType.Kdbndp:
|
|
case SqlSugar.DbType.Sqlite:
|
|
return "不支持的连接类型";
|
|
}
|
|
}
|
|
return "";
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到数据库所有表SQL
|
|
/// </summary>
|
|
private string GetDbTablesSql(SqlSugar.DbType type,string database)
|
|
{
|
|
|
|
switch (type)
|
|
{
|
|
case SqlSugar.DbType.MySql:
|
|
return "select TABLE_NAME, TABLE_COMMENT COMMENTS from information_schema.TABLES where TABLE_SCHEMA='" + database + "' and (table_type='BASE TABLE' or table_type='VIEW')";
|
|
case SqlSugar.DbType.SqlServer:
|
|
return "SELECT name TABLE_NAME,(select top 1 cast([value] as varchar) [value] from sys.extended_properties where major_id=sysobjects.id and minor_id=0) COMMENTS from sysobjects WHERE name<>'sysdiagrams' AND (xtype='U' or xtype='V') ORDER BY xtype,name";
|
|
case SqlSugar.DbType.Oracle:
|
|
return "select a.TABLE_NAME,b.COMMENTS from user_tables a,user_tab_comments b WHERE a.TABLE_NAME=b.TABLE_NAME and a.TABLE_NAME not like '%$%' and a.TABLE_NAME not like 'LOGMNR%' and a.TABLE_NAME not like 'HELP%' and a.TABLE_NAME not like 'SPRING%' and a.TABLE_NAME not like 'SQLPLUS%' order by TABLE_NAME";
|
|
case SqlSugar.DbType.PostgreSQL:
|
|
return "select table_name, '' as comments from information_schema.tables where table_catalog='" + database + "' and table_schema='public' and (table_type='BASE TABLE' or table_type='VIEW')";
|
|
case SqlSugar.DbType.Dm:
|
|
case SqlSugar.DbType.Kdbndp:
|
|
case SqlSugar.DbType.Sqlite:
|
|
return "不支持的连接类型";
|
|
}
|
|
return "";
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个连接所有表
|
|
/// </summary>
|
|
/// <param name="id"></param>
|
|
/// <returns>Dictionary(表名, 表说明)</returns>
|
|
public Dictionary<string, string> GetTables(string id)
|
|
{
|
|
Dictionary<string, string> dict = new Dictionary<string, string>();
|
|
var conn = GetOneById(id);
|
|
if (null == conn)
|
|
{
|
|
return dict;
|
|
}
|
|
DataTable dt = this.GetTables(conn);
|
|
foreach (DataRow dr in dt.Rows)
|
|
{
|
|
dict.Add(dr[0].ToString().Trim(), dr[1].ToString());
|
|
}
|
|
return dict;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询一个连接所有表
|
|
/// </summary>
|
|
/// <param name="dbConnection"></param>
|
|
/// <returns>表名，表说明</returns>
|
|
public DataTable GetTables(Model.rf_dbconnection dbConnection)
|
|
{
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = dbConnection.Id,
|
|
ConnectionString = dbConnection.ConnString,
|
|
DbType = dbConnection.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
var prd = c.GetConnection(dbConnection.Id);
|
|
return prd.Ado.GetDataTable(
|
|
GetDbTablesSql(dbConnection.DbType, prd.Ado.Connection.Database));
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个字段的值(默认系统连接)
|
|
/// </summary>
|
|
/// <param name="sql">SQL</param>
|
|
/// <param name="objs">参数</param>
|
|
/// <returns></returns>
|
|
public string GetFieldValue(string sql, params object[] objs)
|
|
{
|
|
return JObject.FromObject(db.Ado.SqlQuery<dynamic>(sql, objs)).ToString();
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 得到DATATABLE
|
|
/// </summary>
|
|
/// <param name="dbConnectionModel"></param>
|
|
/// <param name="tableName"></param>
|
|
/// <param name="primaryKey"></param>
|
|
/// <param name="primaryKeyValue"></param>
|
|
/// <param name="order">排序 f1 desc</param>
|
|
/// <returns></returns>
|
|
public DataTable GetDataTable(Model.rf_dbconnection dbConnectionModel, string tableName, string primaryKey, string primaryKeyValue, string order = "")
|
|
{
|
|
if (null == dbConnectionModel || primaryKeyValue.IsNullOrWhiteSpace()
|
|
|| tableName.IsNullOrWhiteSpace() || primaryKey.IsNullOrWhiteSpace())
|
|
{
|
|
return new DataTable();
|
|
}
|
|
var (sql, param) = GetFieldValueSql(tableName, "*", primaryKey, primaryKeyValue);
|
|
|
|
DataTable dt = GetDataTable(dbConnectionModel, sql, param);
|
|
if (!order.IsNullOrWhiteSpace())
|
|
{
|
|
dt.DefaultView.Sort = order;
|
|
return dt.DefaultView.ToTable();
|
|
}
|
|
else
|
|
{
|
|
return dt;
|
|
}
|
|
}
|
|
|
|
public DataTable GetDataTable(Model.rf_dbconnection conn, string sql, params object[] objs)
|
|
{
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
var prd = c.GetConnection(conn.Id);
|
|
List<SqlSugar.SugarParameter> list = new List<SqlSugar.SugarParameter>();
|
|
foreach (object o in objs)
|
|
list.Add((SqlSugar.SugarParameter)o);
|
|
return prd.Ado.GetDataTable(sql, list);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到查询一个字段值SQL
|
|
/// </summary>
|
|
/// <param name="tableName"></param>
|
|
/// <param name="fieldName"></param>
|
|
/// <param name="primaryKey"></param>
|
|
/// <param name="primaryKeyValue"></param>
|
|
/// <returns></returns>
|
|
public (string sql, object[] parameter) GetFieldValueSql(string tableName, string fieldName, string primaryKey, string primaryKeyValue)
|
|
{
|
|
string sql = "SELECT " + fieldName + " FROM " + tableName + " WHERE " + primaryKey + " = @primarykeyvalue";
|
|
return (sql, new object[] { new SqlSugar.SugarParameter("primarykeyvalue",primaryKeyValue) } );
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个字段的值
|
|
/// </summary>
|
|
/// <param name="id">连接ID</param>
|
|
/// <param name="tableName">表名</param>
|
|
/// <param name="fieldName">要查询的字段</param>
|
|
/// <param name="primaryKey">主键</param>
|
|
/// <param name="primaryKeyValue">主键值</param>
|
|
/// <returns></returns>
|
|
public string GetFieldValue(string id, string tableName, string fieldName, string primaryKey, string primaryKeyValue)
|
|
{
|
|
var conn = GetOneById(id);
|
|
if (null == conn)
|
|
{
|
|
return string.Empty;
|
|
}
|
|
return GetFieldValue(conn, tableName, fieldName, primaryKey, primaryKeyValue);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到一个字段的值
|
|
/// </summary>
|
|
/// <param name="dbConnection">连接实体</param>
|
|
/// <param name="tableName">表名</param>
|
|
/// <param name="fieldName">要查询的字段</param>
|
|
/// <param name="primaryKey">主键</param>
|
|
/// <param name="primaryKeyValue">主键值</param>
|
|
/// <returns></returns>
|
|
public string GetFieldValue(Model.rf_dbconnection dbConnection, string tableName, string fieldName, string primaryKey, string primaryKeyValue)
|
|
{
|
|
var sql = GetFieldValueSql(tableName, fieldName, primaryKey, primaryKeyValue);
|
|
DataTable dataTable = GetDataTable(dbConnection, sql.sql, sql.parameter );
|
|
return dataTable.Rows.Count > 0 ? dataTable.Rows[0][0].ToString() : string.Empty;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 保存数据
|
|
/// </summary>
|
|
/// <param name="dbConnection"></param>
|
|
/// <param name="tuples"></param>
|
|
/// <param name="isIdentity"></param>
|
|
/// <param name="seqName"></param>
|
|
/// <param name="sqlList">要额外执行的SQL列表</param>
|
|
/// <returns>返回数字表示成功（数字是受影响的行数或者自增主键值），其它为错误信息</returns>
|
|
public string SaveData(Model.rf_dbconnection dbConnection, List<(Dictionary<string, object> dicts, string tableName, string primaryKey, int flag)> tuples,
|
|
bool isIdentity = false, string seqName = "", List<(string, SqlSugar.SugarParameter[])> sqlList = null)
|
|
{
|
|
return tuples.Count == 0 && (sqlList == null || sqlList.Count == 0) ? "0" : SaveData2(dbConnection, tuples, isIdentity, seqName, sqlList);
|
|
}
|
|
|
|
/// <summary>
|
|
/// 保存数据
|
|
/// </summary>
|
|
/// <param name="tuples"></param>
|
|
/// <param name="sqlList1">要额外执行的SQL列表</param>
|
|
/// <returns>返回数字表示成功（数字是受影响的行数或者自增主键值），其它为错误信息</returns>
|
|
public string SaveData2(Model.rf_dbconnection dbConnection, List<(Dictionary<string, object> dicts, string tableName, string primaryKey, int flag)> tuples,
|
|
bool isIdentity = false, string seqName = "", List<(string, SqlSugar.SugarParameter[])> sqlList1 = null)
|
|
{
|
|
|
|
List<(string sql, SqlSugar.SugarParameter[] parameters)> sqlList = new List<(string sql, SqlSugar.SugarParameter[] parameters)>();
|
|
foreach (var (dicts, tableName, primaryKey, flag) in tuples)
|
|
{
|
|
var (sql, paramArray) = GetSaveDataSql(dicts, tableName, primaryKey, flag);
|
|
sqlList.Add((sql, paramArray));
|
|
}
|
|
if (sqlList1 != null && sqlList1.Count > 0)
|
|
{
|
|
sqlList.AddRange(sqlList1);
|
|
}
|
|
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = dbConnection.Id,
|
|
ConnectionString = dbConnection.ConnString,
|
|
DbType = dbConnection.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
var prd = c.GetConnection(dbConnection.Id);
|
|
prd.Ado.BeginTran();
|
|
try
|
|
{
|
|
int i = 0;
|
|
foreach (var (sql, parameter) in sqlList)
|
|
{
|
|
i += prd.Ado.ExecuteCommand(sql, parameter);
|
|
}
|
|
if (isIdentity && !seqName.IsNullOrWhiteSpace())
|
|
{
|
|
i = prd.Ado.SqlQuery<int>("SELECT @@IDENTITY")[0];
|
|
}
|
|
prd.Ado.CommitTran();
|
|
return i.ToString();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
prd.Ado.RollbackTran();
|
|
}
|
|
|
|
}
|
|
return "-1";
|
|
}
|
|
|
|
/// <summary>
|
|
/// 得到保存数据SQL
|
|
/// </summary>
|
|
/// <param name="dicts"></param>
|
|
/// <param name="flag">0删除 1新增 2修改</param>
|
|
/// <returns></returns>
|
|
public (string sql, SqlSugar.SugarParameter[] parameter) GetSaveDataSql(Dictionary<string, object> dicts, string tableName, string primaryKey, int flag)
|
|
{
|
|
StringBuilder sqlBuilder = new StringBuilder();
|
|
List<SqlSugar.SugarParameter> parameters = new List<SqlSugar.SugarParameter>();
|
|
if (0 == flag)
|
|
{
|
|
sqlBuilder.Append("DELETE FROM " + tableName);
|
|
}
|
|
else if (1 == flag)
|
|
{
|
|
sqlBuilder.Append("INSERT INTO " + tableName + "(");
|
|
foreach (var dict in dicts)
|
|
{
|
|
sqlBuilder.Append(dict.Key);
|
|
if (!dict.Key.Equals(dicts.Last().Key))
|
|
{
|
|
sqlBuilder.Append(",");
|
|
}
|
|
}
|
|
sqlBuilder.Append(") VALUES(");
|
|
}
|
|
else if (2 == flag)
|
|
{
|
|
sqlBuilder.Append("UPDATE " + tableName + " SET ");
|
|
}
|
|
foreach (var dict in dicts)
|
|
{
|
|
if (0 == flag)
|
|
{
|
|
sqlBuilder.Append(" WHERE " + primaryKey + "=@" + primaryKey);
|
|
parameters.Add(new SqlSugar.SugarParameter("@" + primaryKey, dicts[primaryKey]));
|
|
}
|
|
else if (1 == flag)
|
|
{
|
|
parameters.Add(new SqlSugar.SugarParameter("@" + dict.Key, dict.Value));
|
|
sqlBuilder.Append("@" + dict.Key);
|
|
if (!dict.Key.Equals(dicts.Last().Key))
|
|
{
|
|
sqlBuilder.Append(",");
|
|
}
|
|
}
|
|
else if (2 == flag)
|
|
{
|
|
parameters.Add(new SqlSugar.SugarParameter("@" + dict.Key, dict.Value));
|
|
if (dict.Key.EqualsIgnoreCase(primaryKey))
|
|
{
|
|
continue;
|
|
}
|
|
sqlBuilder.Append(dict.Key + "=@" + dict.Key);
|
|
if (!dict.Key.Equals(dicts.Last().Key))
|
|
{
|
|
sqlBuilder.Append(",");
|
|
}
|
|
}
|
|
}
|
|
if (1 == flag)
|
|
{
|
|
sqlBuilder.Append(")");
|
|
}
|
|
else if (2 == flag)
|
|
{
|
|
sqlBuilder.Append(" WHERE " + primaryKey + "=@" + primaryKey);
|
|
}
|
|
return (sqlBuilder.ToString(), parameters.ToArray());
|
|
}
|
|
|
|
/// <summary>
|
|
/// 判断一个连接是否和系统是一个连接
|
|
/// </summary>
|
|
/// <param name="connId"></param>
|
|
/// <returns></returns>
|
|
public bool IsSystemConn(Model.rf_dbconnection connModel)
|
|
{
|
|
var con =db.CurrentConnectionConfig;
|
|
return true;
|
|
}
|
|
|
|
public int executeSqlByConnection(Model.rf_dbconnection conn, IEnumerable<(string, object[], int)> list, bool trans = true)
|
|
{
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
if(trans)
|
|
c.BeginTran();
|
|
try
|
|
{
|
|
int count = 0;
|
|
foreach (var (sql, pars, _) in list)
|
|
count = c.Ado.ExecuteCommand(sql, pars);
|
|
if (trans)
|
|
c.CommitTran();
|
|
return count;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (trans)
|
|
c.RollbackTran();
|
|
throw;
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public int executeSqlByConnection(Model.rf_dbconnection conn, string sql,params object[] pars)
|
|
{
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
return c.Ado.ExecuteCommand(sql, pars);
|
|
}
|
|
|
|
}
|
|
public int executeSqlByConnection(string connId, List<(string, IEnumerable<object>)> sqls)
|
|
{
|
|
var conn = GetOneById(connId);
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
c.Ado.BeginTran();
|
|
try
|
|
{
|
|
int count = 0;
|
|
foreach ((string sql, IEnumerable<object> pars) in sqls)
|
|
{
|
|
count +=c.Ado.ExecuteCommand(sql, pars);
|
|
}
|
|
c.Ado.CommitTran();
|
|
return count;
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
c.Ado.RollbackTran();
|
|
throw;
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public int executeSqlByCurrent(IEnumerable<(string, object[], int)> list,bool trans=true)
|
|
{
|
|
if (trans)
|
|
db.BeginTran();
|
|
try
|
|
{
|
|
int count = 0;
|
|
foreach (var (sql, pars, _) in list)
|
|
count = db.Ado.ExecuteCommand(sql, pars);
|
|
if (trans)
|
|
db.CommitTran();
|
|
return count;
|
|
}
|
|
catch
|
|
{
|
|
if (trans)
|
|
db.RollbackTran();
|
|
throw;
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 测试一个SQL语句是否正确
|
|
/// </summary>
|
|
/// <param name="id">连接ID</param>
|
|
/// <param name="sql">sql语句</param>
|
|
/// <param name="parameters">sql参数</param>
|
|
/// <returns></returns>
|
|
public string TestSQL(string id, string sql, object[] parameters = null)
|
|
{
|
|
var conn = GetOneById(id);
|
|
if (conn == null)
|
|
return "未找到连接实体";
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
c.Ado.BeginTran();
|
|
try {
|
|
int rtn = c.Ado.ExecuteCommand(sql, parameters);
|
|
return rtn.ToString();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return "SQL:" + sql + " " + ex.Message;
|
|
}
|
|
finally {
|
|
c.Ado.RollbackTran();
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 得到连接类别下拉项(VUE)
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
public JArray GetConnTypeOptionsVue()
|
|
{
|
|
JArray jArray = new JArray();
|
|
var array = Enum.GetValues(typeof(ConnType));
|
|
foreach (var arr in array)
|
|
{
|
|
jArray.Add(new JObject() { { "value", arr.ToString() }, { "title", arr.ToString() } });
|
|
}
|
|
return jArray;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 测试一个连接
|
|
/// </summary>
|
|
/// <param name="id">连接ID</param>
|
|
/// <param name="localizer">语言包</param>
|
|
/// <returns>返回"1"表示正常，其它为错误信息</returns>
|
|
public string TestConnection(string id, IStringLocalizer localizer = null)
|
|
{
|
|
var conn = this.GetOneById(id);
|
|
if (conn == null)
|
|
return localizer == null ? "未找到连接" : localizer["NotFoundConnection"].Value;
|
|
using (SqlSugar.SqlSugarClient c = new SqlSugar.SqlSugarClient(new SqlSugar.ConnectionConfig()
|
|
{
|
|
ConfigId = conn.Id,
|
|
ConnectionString = conn.ConnString,
|
|
DbType = conn.DbType,
|
|
IsAutoCloseConnection = true,
|
|
InitKeyType = SqlSugar.InitKeyType.SystemTable
|
|
}))
|
|
{
|
|
return "1";
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 数据连接类型枚举
|
|
/// </summary>
|
|
public enum ConnType
|
|
{
|
|
SqlServer,
|
|
MySql,
|
|
Oracle,
|
|
PostgreSql
|
|
}
|
|
}
|