using MES.Service.util;
using SqlSugar;

namespace MES.Service.DB;

public class RepositoryNoEntity
{
    protected static SqlSugarScope Db = new(new ConnectionConfig
        {
            DbType = DbType.Oracle,
            ConnectionString = AppsettingsUtility.Settings.DataBaseConn,
            IsAutoCloseConnection = true
        },
        db =>
        {
            db.Aop.OnLogExecuting = (sql, pars) =>
            {
                Console.WriteLine(
                    UtilMethods.GetSqlString(DbType.Oracle, sql, pars));
            };
        });


    protected int UseTransaction(Func<SqlSugarScope, int> action)
    {
        try
        {
            Db.Ado.BeginTran(); // 开始事务
            var affectedRows = action.Invoke(Db); // 执行传入的操作并获取受影响的行数
            Db.Ado.CommitTran(); // 提交事务
            return affectedRows; // 返回受影响的行数
        }
        catch (Exception)
        {
            Db.Ado.RollbackTran(); // 回滚事务
            throw; // 重新抛出异常
        }
    }
}