using MES.Service.util;
using SqlSugar;

namespace MES.Service.DB;

public class SqlSugarHelper
{
    private static readonly string _connectionString =
        AppsettingsUtility.Settings.DataBaseConn; // 这里替换成你的实际连接字符串

    public static SqlSugarClient GetInstance()
    {
        var db = new SqlSugarClient(new ConnectionConfig
        {
            ConnectionString = _connectionString,
            DbType = DbType.Oracle,
            IsAutoCloseConnection = true, //开启自动释放模式和EF原理一样我就不多解释了
            InitKeyType = InitKeyType.Attribute
        });


        //调式代码 用来打印SQL 
        db.Aop.OnLogExecuting = (sql, pars) =>
        {
            Console.WriteLine(
                UtilMethods.GetSqlString(DbType.Oracle, sql, pars));
        };
        return db;
    }

    public static int UseTransactionWithOracle(Func<SqlSugarClient, int> action)
    {
        using (var db = GetInstance())
        {
            try
            {
                db.Ado.BeginTran(); // 开始事务
                var affectedRows = action.Invoke(db); // 执行传入的操作并获取受影响的行数
                db.Ado.CommitTran(); // 提交事务
                return affectedRows; // 返回受影响的行数
            }
            catch (Exception ex)
            {
                db.Ado.RollbackTran(); // 回滚事务
                throw ex;
            }
        }
    }
}