SourceCode/RFrameGenerate.DAL/Factory/IFactory.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using RFramework.SQLServer;
using RFrameGenerate.DAL.Interface;
using RFrameGenerate.DAL.SQLServer;
using RFrameGenerate.Model;
using RFrameGenerate.Common.DatabaseConfig;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;

namespace RFrameGenerate.DAL
{
    public abstract class IFactory
    { 
        #region 核心
        /// <summary>
        /// 获取连接对象
        /// </summary>
        /// <returns></returns>
        protected static SqlRTransaction GetSqlConnection()
        {
            return new SqlRTransaction();
        }
        /// <summary>
        /// 根据完整命名空间创建对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="tableName">对象名</param>
        /// <returns></returns>
        protected static IQuery<T> CreateInstance<T>(string tableName, SqlRTransaction transaction)
        {
            string className = string.Format("{0}.{1}.{2}", Database.AssemblyName, Database.DatabaseType, tableName);
            IQuery<T> iquery = (IQuery<T>)Assembly.Load(Database.AssemblyName).CreateInstance(className);

            if (iquery != null)
            {
                if (transaction == null)
                {
                    iquery.sqlRTransaction = GetSqlConnection();
                }
                else
                {
                    iquery.sqlRTransaction = transaction;
                }
            }
            else
            {
                throw new Exception("路径错误!");
            }
            return iquery;
        }
        /// <summary>
        /// 调用自定义存储过程
        /// </summary>
        /// <param name="transaction">连接事务</param>
        /// <returns></returns>
        public static IProcedure CreateProcedure(SqlRTransaction transaction = null)
        {
            if (transaction == null)