smartsoft.common.sql.dbfactory.cs

一个通用的数据库操作类,可以访问ACESS,SQLServer,Oracle,OleDB等,并提供常用对表的读取及更新操作。

            {
                别名值 = this.数据值查询String("别名", CommandType.Text,SQL语句, 数据库命令参数CommandParameters);
            }
            return 别名值;
        }
        protected byte[] 视图表字段字节值BY文本命令(string 数值表达式X, string 视图表达式X, string 查询条件表达式X, string 分组表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            byte[] 别名值 = null;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据列(数值表达式X, "别名", 视图表达式X, 查询条件表达式X, 分组表达式X);
            if (SQL语句 != "")
            {
                别名值 = this.数据值查询Byte("别名", CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
            }
            return 别名值;
        }
        //------------
        #endregion 扩展命令 通用视图表值查询

    }

    public abstract class DBFactory数据库数据表类 : DBFactory数据库基础类
    {
        #region 构造函数
        public DBFactory数据库数据表类(SmartSoft.Common.SQL.数据库类型 数据库类型enum, string 数据库链接字符串String)
            : base(数据库类型enum, 数据库链接字符串String)
        {

        }

        #endregion 构造函数

        #region 扩展命令 通用数据表记录查询
        //---------------
        protected System.Data.IDataReader 数据表通用DataReader查询BY文本命令(string 数据序列表达式X, string 数据表名称X, string 查询条件表达式X, string 分组表达式X, string 排序表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            System.Data.IDataReader SELECT表记录 = null;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据行(数据序列表达式X, 数据表名称X, 查询条件表达式X, 分组表达式X, 排序表达式X);
            if (数据表名称X != "")
            {
                if (数据序列表达式X != "")
                {
                    if (SQL语句 != "")
                    {

                        SELECT表记录 = this.通用DataReader查询(CommandType.Text,SQL语句, 数据库命令参数CommandParameters);
                    }
                }
            }
            return SELECT表记录;
        }
        protected System.Data.DataTable 数据表通用DataTable查询BY文本命令(string 数据序列表达式X, string 数据表名称X, string 查询条件表达式X, string 分组表达式X, string 排序表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            System.Data.DataTable SELECT表记录 = new System.Data.DataTable();
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据行(数据序列表达式X, 数据表名称X, 查询条件表达式X, 分组表达式X, 排序表达式X);
            if (数据表名称X != "")
            {
                if (数据序列表达式X != "")
                {
                    if (SQL语句 != "")
                    {

                        SELECT表记录 = this.通用DataTable查询(数据表名称X, CommandType.Text,SQL语句, 数据库命令参数CommandParameters);
                    }
                }
            }
            return SELECT表记录;
        }
        protected System.Data.DataSet 数据表通用DataSet查询BY文本命令(string 数据序列表达式X, string 数据表名称X, string 查询条件表达式X, string 分组表达式X, string 排序表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            System.Data.DataSet SELECT表记录 = new System.Data.DataSet();
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据行(数据序列表达式X, 数据表名称X, 查询条件表达式X, 分组表达式X, 排序表达式X);
            if (数据表名称X != "")
            {
                if (数据序列表达式X != "")
                {
                    if (SQL语句 != "")
                    {

                        SELECT表记录 = this.通用DataSet查询(数据表名称X,CommandType.Text,SQL语句, 数据库命令参数CommandParameters);
                    }
                }
            }
            return SELECT表记录;
        }
        //---------------------
        #endregion 扩展命令 通用数据表记录查询

        #region 扩展命令 通用数据表值查询
        //------------------
        protected string 数据表字段文本值BY文本命令(string 数值表达式X, string 数据表名称X, string 查询条件表达式X, string 分组表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            string 别名值 = "";
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据列(数值表达式X, "别名", 数据表名称X, 查询条件表达式X, 分组表达式X);
            if (SQL语句 != "")
            {
                别名值 = this.数据值查询String("别名", CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
            }
            return 别名值;
        }
        protected byte[] 数据表字段字节值BY文本命令(string 数值表达式X, string 数据表名称X, string 查询条件表达式X, string 分组表达式X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            byte[] 别名值 = null;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.获取数据列(数值表达式X, "别名", 数据表名称X, 查询条件表达式X, 分组表达式X);
            if (SQL语句 != "")
            {
                别名值 = this.数据值查询Byte("别名", CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
            }
            return 别名值;
        }
        //------------
        #endregion 扩展命令 通用数据表值查询

        #region 扩展命令 删除通用数据表记录
        protected bool 数据表删除记录BY文本命令(string 数据表名称X, string 条件X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            bool IsOk = false;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.删除表记录(数据表名称X, 条件X);
            if (SQL语句 != "")
            {
                this.数据库命令非查询(CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
                IsOk = this.操作正确否;
            }
            return IsOk;
        }
        #endregion 扩展命令 删除通用数据表记录

        #region 扩展命令 新建通用数据表记录
        protected bool 数据表新建记录BY文本命令(string 字段序列X, string 数据表名称X, string 字段值序列X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            bool IsOk = false;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.新建表记录(字段序列X, 数据表名称X, 字段值序列X);
            if (SQL语句 != "")
            {
                this.数据库命令非查询(CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
                IsOk = this.操作正确否;
            }
            return IsOk;
        }
        #endregion 扩展命令 新建通用数据表记录

        #region 扩展命令 更新通用数据表记录
        protected bool 数据表更新记录BY文本命令(string 数据表名称X, string 更新达式X, string 更新条件X, params IDbDataParameter[] 数据库命令参数CommandParameters)
        {
            bool IsOk = false;
            string SQL语句 = SmartSoft.Common.SQL.SQLExpression.SQL语句.更新表记录(数据表名称X, 更新达式X, 更新条件X);
            if (SQL语句 != "")
            {
                this.数据库命令非查询(CommandType.Text, SQL语句, 数据库命令参数CommandParameters);
                IsOk = this.操作正确否;
            }
            return IsOk;
        }
        #endregion 扩展命令 更新通用数据表记录

    }


    #region  基础命令 数据基础操作

    //-------------------

    public static class 数据库链接
    {
        public static System.Data.IDbConnection 创建数据库链接Connection(string 数据库类型String, string 数据库链接字符串String)
        {
            System.Data.Common.DbProviderFactory 数据工厂DbProviderFactory = System.Data.Common.DbProviderFactories.GetFactory(数据库类型String);
            System.Data.IDbConnection 数据库链接ConnectionX = 数据工厂DbProviderFactory.CreateConnection();

            数据库链接ConnectionX.ConnectionString = 数据库链接字符串String;
            //数据库链接ConnectionX.Open();
            return 数据库链接ConnectionX;
        }

        public static System.Data.ConnectionState 链接状态(System.Data.IDbConnection 数据库链接Connection)
        {
            System.Data.ConnectionState 数据库链接状态 = 数据库链接Connection.State;
            return 数据库链接状态;
        }


        public static bool 数据库链接打开(System.Data.IDbConnection 数据库链接Connection)
        {
            bool 数据库链接IsOk = false;

            if (链接状态(数据库链接Connection) == System.Data.ConnectionState.Open)
            {
                数据库链接IsOk = true;
            }
            else
            {
                数据库链接Connection.Open();
                if (链接状态(数据库链接Connection) == System.Data.ConnectionState.Open)
                {
                    数据库链接IsOk = true;
                }
                else
                {
                    数据库链接IsOk = false;
                }
            }

            return 数据库链接IsOk;
        }

        public static bool 数据库链接关闭(System.Data.IDbConnection 数据库链接Connection)
        {
            bool 数据库链接IsOk = false;

            if (链接状态(数据库链接Connection) == System.Data.ConnectionState.Closed)
            {
                数据库链接IsOk = true;
            }
            else
            {
                数据库链接Connection.Close();
                if (链接状态(数据库链接Connection) == System.Data.ConnectionState.Closed)
                {
                    数据库链接IsOk = true;
                }
                else
                {
                    数据库链接IsOk = false;
                }
            }

            return 数据库链接IsOk;
        }

        public static bool 数据库链接是否正确(System.Data.IDbConnection 数据库链接Connection)
        {
            bool 数据库链接IsOk = false;
            数据库链接IsOk = (SmartSoft.Common.SQL.DBFactory.数据库链接.数据库链接打开(数据库链接Connection) && SmartSoft.Common.SQL.DBFactory.数据库链接.数据库链接关闭(数据库链接Connection));
            return 数据库链接IsOk;
        }

        public static bool 数据库链接是否正确(string 数据库类型String, string 数据库链接字符串String)
        {
            bool 数据库链接IsOk = false;
            数据库链接IsOk = SmartSoft.Common.SQL.DBFactory.数据库链接.数据库链接是否正确(SmartSoft.Common.SQL.DBFactory.数据库链接.创建数据库链接Connection(数据库类型String, 数据库链接字符串String));
            return 数据库链接IsOk;
        }


        public static string 数据库名称(string 数据库类型String, string 数据库链接字符串String)
        {
            string 数据库名称String = "";
            System.Data.IDbConnection 数据库链接ConnectionX = SmartSoft.Common.SQL.DBFactory.数据库链接.创建数据库链接Connection(数据库类型String, 数据库链接字符串String);
            数据库名称String = 数据库链接ConnectionX.Database;
            return 数据库名称String;
        }

        public static string 数据库实例(string 数据库类型String, string 数据库链接字符串String)
        {
            string 数据库实例String = "";
            System.Data.IDbConnection 数据库链接ConnectionX = SmartSoft.Common.SQL.DBFactory.数据库链接.创建数据库链接Connection(数据库类型String, 数据库链接字符串String);
            数据库实例String = 数据库链接ConnectionX.Database;
            return 数据库实例String;
        }

    }

    public static class 数据库命令
    {
        public static System.Data.IDbDataParameter 创建命令参数CommandParameterObject(string 数据库类型String, string 参数名称String, object 参数值Object, System.Data.DbType 数据类型DbType, System.Data.ParameterDirection 参数方向ParameterDirection)
        {
            System.Data.Common.DbProviderFactory 数据工厂DbProviderFactory = System.Data.Com