You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

162 lines
5.4 KiB
C#

using CommonFunc.Tools;
using System;
using System.Data;
using System.Data.SqlClient;
namespace CommonFunc
{
/// <summary>
/// 数据对象类
/// </summary>
public class SqlDataObject
{
/// <summary>
/// 返回一sql连接对象
/// </summary>
/// <param name="path">配置文件的相对路径</param>
/// <returns>数据库连接对象</returns>
public static SqlConnection GetSqlConnection(string path)
{
ConnectionConfig conSetting = DatabaseConfig.GetSettings(path);
return new SqlConnection(CommonFunc.DESProvider.DecryptString(conSetting.SqlConnectionString));
}
/// <summary>
/// 返回一sql连接对象
/// </summary>
/// <returns>数据库连接对象</returns>
public static SqlConnection GetSqlConnection()
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return new SqlConnection(CommonFunc.DESProvider.DecryptString(conSetting.SqlConnectionString));
}
///// <summary>
///// 返回一oracle连接对象
///// </summary>
///// <param name="path">配置文件的相对路径</param>
///// <returns>数据库连接对象</returns>
//public static OracleConnection GetOracleConnection(string path)
//{
// ConnectionConfig conSetting = DatabaseConfig.GetSettings(path);
// return new OracleConnection(HS.Common.DEncrypt.DESEncrypt.Decrypt(conSetting.OracleConnectionString));
//}
///// <summary>
///// 返回一oracle连接对象
///// </summary>
///// <returns>数据库连接对象</returns>
//public static OracleConnection GetOracleConnection()
//{
// ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
// return new OracleConnection(HS.Common.DEncrypt.DESEncrypt.Decrypt(conSetting.OracleConnectionString));
//}
/// <summary>
/// 返回一sql连接字符串
/// </summary>
public static string GetSqlConnectionString
{
get
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.SqlConnectionString);
}
}
/// <summary>
/// 返回一sql连接字符串
/// </summary>
public static string GetMySqlConnectionString
{
get
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.MySqlConnectionString);
}
}
/// <summary>
/// 返回一sql连接字符串
/// </summary>
public static string GetMESSqlConnectionString
{
get
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.MESConnectionString);
}
}
/// <summary>
/// 获取云库链接串
/// </summary>
public static string GetCloudSqlConnectionString
{
get
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.CloudConnectionString);
}
}
/// <summary>
/// 获取网络业务库
/// </summary>
public static string GetMESNetClientSqlConnectionString
{
get
{
string sql = $"SELECT db_url FROM[dbo].[sys_datasource] where dept_id = '{Utils.GetAppSetting("SiteCode")}'";
DataTable dt = Utils.cloudDBHelper.getDataSet(sql).Tables[0];
if (dt == null || dt.Rows.Count <= 0 || string.IsNullOrEmpty(dt.Rows[0][0].ToString()))
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.MESNetClientConnectionString);
}
else
{
return dt.Rows[0][0].ToString();
}
}
}
/// <summary>
/// 获取本地业务库
/// </summary>
public static string GetMESClientSqlConnectionString
{
get
{
ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
return CommonFunc.DESProvider.DecryptString(conSetting.MESClientConnectionString);
}
}
///// <summary>
///// 返回一oracle连接字符串
///// </summary>
//public static string GetOracleConnectionString
//{
// get
// {
// ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
// return HS.Common.DEncrypt.DESEncrypt.Decrypt(conSetting.OracleConnectionString);
// }
//}
///// <summary>
///// 返回一ado连接字符串
///// </summary>
//public static string GetAdoConnectionString
//{
// get
// {
// ConnectionConfig conSetting = DatabaseConfig.GetSettingsDirectory();
// return HS.Common.DEncrypt.DESEncrypt.Decrypt(conSetting.AdoConnectionString);
// }
//}
}
}