using Ant.ORM;
using Ant.Utility;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;

namespace Ant.Core
{
    class DbSession : IDbSession
    {
        DbContext _dbContext;
        internal DbSession(DbContext dbContext)
        {
            this._dbContext = dbContext;
        }
        public IDbContext DbContext { get { return this._dbContext; } }
        public bool IsInTransaction { get { return this._dbContext.InnerDbSession.IsInTransaction; } }
        /// <summary>
        /// 返回执行影响的条数
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        public int ExecuteNonQuery(string sql, params DbParam[] parameters)
        {
            Utils.CheckNull(sql, "sql");
            return this._dbContext.InnerDbSession.ExecuteNonQuery(sql, parameters);
        }
        /// <summary>
        /// 返回首行首列数据
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        public object ExecuteScalar(string sql, params DbParam[] parameters)
        {
            Utils.CheckNull(sql, "sql");
            return this._dbContext.InnerDbSession.ExecuteScalar(sql, parameters);
        }
        /// <summary>
        /// 只读方式执行SQL语句
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        public IDataReader ExecuteReader(string sql, params DbParam[] parameters)
        {
            Utils.CheckNull(sql, "sql");
            return this._dbContext.InnerDbSession.ExecuteInternalReader(sql, parameters, CommandType.Text);
        }
        /// <summary>
        /// 开启事务
        /// </summary>
        public void BeginTransaction()
        {
            this._dbContext.InnerDbSession.BeginTransaction();
        }
        /// <summary>
        /// 开启事务
        /// </summary>
        /// <param name="il"></param>
        public void BeginTransaction(IsolationLevel il)
        {
            this._dbContext.InnerDbSession.BeginTransaction(il);
        }
        /// <summary>
        /// 提交事务
        /// </summary>
        public void CommitTransaction()
        {
            this._dbContext.InnerDbSession.CommitTransaction();
        }
        /// <summary>
        /// 回滚事务
        /// </summary>
        public void RollbackTransaction()
        {
            this._dbContext.InnerDbSession.RollbackTransaction();
        }
        /// <summary>
        /// 释放资源
        /// </summary>
        public void Dispose()
        {
            this._dbContext.Dispose();
        }
    }
}