简单跨数据库ADO.NET组件-DAM

时间：2011-01-28 来源：Rainr

它的特点：

在您保证SQL语句兼容的前提下，透过它来访问数据库时，在不需要改变DAL层一点代码的前提下，只要修改一下配置文件，它便可以为你跨不同类型的数据库。
让你的DAL层代码更见简练。它会根据配置文件配置的连接信息，自动为你创建数据库连接，执行操作。关闭连接，释放连接等.
让DAL层的不同模块访问不同类型或不同数据库更加方便。
不错的执行效率，它基于原生ADO.NET。只会反射一次访问不同数据库的ADO提供者的程序集(DAM最终都是通过这些提供者来实现访问不同类型数据库的)。

它的配置：

配置代码 <appsettings>
  <add key="rpsconnection" value="mssql"/>
  <add key="damconnection" value="sqlite" />
</appsettings>
<connectionstrings>
  <add name="sqlite" connectionString="" providerName="System.Data.SQLite.SQLiteConnection;System.Data.SQLite"/>
  <add name="mssql" connectionString="" providerName="System.Data.SqlClient.SqlConnection;System.Data" />
</connectionstrings>
appsettings 1.添加一个KV。KEY="damconnection" VALUE="下面connectionstrings中的一个name的一项"."damconnection"为默认的DAM读取的KEY, KEY的名字请不要更换. VALUE的值可以根据您默认连接的数据库连接变而变.
2.如果想应用多个数据库连接，来访问不同的数据库. 您可以在appsettings中添加别的KV项.代码里使用DAM中Config或者Factroy来创建不同的数据库连接，可以实现访问不同的或不同类型的数据库.

connectionstrings 1.项中connectionString值不需要变
2.项中providerName值分为三个部分

连接的完整类名 ; 连接类所在的程序集名

(命名空间+类名) (中间用";"分开) (注意不加.dll)

测试代码：

DAL层测试代码

/// <summary>
    /// 数据访问层
    /// 透过Dam访问数据库
    /// </summary>
    public class DALTest
    {
        /// <summary>
        /// 最简单的插入操作
        /// Execute会帮你自动创建所对应数据库的连接、执行操作、释放Command、关闭连接、释放链接等
        /// </summary>
        /// <returns>执行后受影响行数</returns>
        public int Insert()
        {
            return Execute.SExecuteNonQuery("sp_name", null);
            //return Execute.SExecuteNonQuery("insert into tablename (..) values (..)", CommandType.Text , null);
        }

        /// <summary>
        /// 带参数的插入操作
        /// Execute会帮你自动创建所对应数据库的连接
        /// 并帮你把参数类型转换为所对应数据库类型的参数进行数据库操作.
        /// </summary>
        /// <returns></returns>
        public int Insert_Paras()
        {
            DbParameter[] paras =
            {
                new MySqlParameter("p1","p1value")
                ,new SqlParameter("p2","p2value")
            };
            return Execute.SExecuteNonQuery("sp_name", paras);
        }

        /// <summary>
        /// 带参数的插入操作，并能得到参数返回值
        /// Execute会帮你自动创建所对应数据库的连接
        /// 并帮你把参数类型转换为所对应数据库类型的参数进行数据库操作.
        /// 执行完成您可得到返回值
        /// </summary>
        /// <returns></returns>
        public int Insert_Paras(ref string outputValue)
        {
            int resultInt = 0;
            DbParameter[] paras =
            {
                new MySqlParameter("p1","p1value")
                ,new SqlParameter("p2_output","")
                {
                     Direction = ParameterDirection.Output
                }
            };
            resultInt = Execute.SExecuteNonQuery("sp_name", paras);
            if (paras[1].Value != null) outputValue = paras[1].Value.ToString();
            return resultInt;
        }

        /// <summary>
        /// 带参数的插入操作，并能得到参数返回值，此参数从BLL层传来
        ///同上...
        /// </summary>
        /// <returns></returns>
        public int Insert_Paras(DbParameter[] paras)
        {
            return Execute.SExecuteNonQuery("sp_name", paras);
            //这样可以在BLL层通过 paras[1]来获取返回参数了
        }

        /// <summary>
        /// 执行同连接多操作的事务处理
        /// 这里使用1个带参数的存储过程和一个不带参数的sql语句操作
        /// 使用是静态调用方法
        /// </summary>
        /// <returns></returns>
        public bool Insert_Transaction()
        {
            bool resultBool = false;
            DbParameter[] paras =
            {
                new MySqlParameter("p1","p1value")
                ,new SqlParameter("p2","p2value")
            };
            DbConnection connection = null;
            DbTransaction transaction = null;
            try
            {
                connection = Factory.CreateConnection();
                connection.Open();
                transaction = connection.BeginTransaction();
                int resultInt1 = Execute.SExecuteNonQuery(connection, transaction, "sp_name1", paras);
                int resultInt2 = Execute.SExecuteNonQuery(connection, transaction, "insert into tablename (...) values (...)", null);
                if (resultInt1 > 0 && resultInt2 > 0)
                {
                    transaction.Commit();
                    resultBool = true;
                }
                else
                {
                    transaction.Rollback();
                }
            }
            catch (Exception)
            {
                if (transaction != null)
                {
                    transaction.Rollback();
                }
            }
            finally
            {
                if (transaction != null)
                {
                    transaction.Dispose();
                }
                if (connection != null)
                {
                    //这里需要手动关闭连接！！
                    connection.Close();
                    connection.Dispose();
                }
            }
            return resultBool;
        }

        /// <summary>
        /// 执行同连接多任务操作（不使用事务）
        /// 这里我们使用对象方法。这样执行多任务操作可能会稳定点和效率高点
        /// </summary>
        /// <returns></returns>
        public void Insert_much()
        {
            Execute exec = Execute.NewExecute;
            DbConnection connection = null;
            try
            {
                connection = Factory.CreateConnection();
                exec.ExecuteNonQuery(connection, null, "sp_name", null);
                exec.ExecuteNonQuery(connection, null, "sp_name2", null);
            }
            finally
            {
                if (connection != null)
                {
                    //因为调用了带事务的那个方法（但是我们设置事务为NULL，事务无效）
                    //所以连接不会自动关闭释放，我们需要手动释放
                    connection.Close();
                    connection.Dispose();
                }
            }
        }

    }

Dam: Dam.rar

有兴趣的可以看看:) 内部有帮助文档。