public ReaderGroup GetReaderGroup(int groupID)
        {
            try
            {
                using (var dbhelper = new DbHelper())
                {
                    // Fetch Reader Group
                    dbhelper.Command.CommandType = System.Data.CommandType.Text;
                    dbhelper.Command.CommandText = "SELECT [ReaderGroupID],[ReaderGroupName],[ReaderGroupDescription],[ReaderGroupLocation],[ReaderGroupZone] ,[ReaderDBConnectionString],[ReaderWCFConnectionString] FROM [RF].[ReaderGroup] WHERE [ReaderGroupID] = " + groupID.ToString();
                    DataSet ds = dbhelper.ExcuteDatset(dbhelper.Command);
                    if (ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                        throw new Exception("Reader Group not found for ID " + groupID);

                    ReaderGroup rdrGrp = DbHelper.DataTableToList<ReaderGroup>(ds.Tables[0]).FirstOrDefault();

                    // Fetch Readers
                    dbhelper.Command.CommandType = System.Data.CommandType.Text;
                    dbhelper.Command.CommandText = "SELECT [ReaderID],[ReaderGroupID],[ReaderTypeID],[ReaderName],[ReaderDescription],[IPAddress],[PortNo],[MACAddress],[AntennaPower],[ReaderPower],[LocationRef],[LocationDescription],[IsDeleted]  FROM [RF].[Reader] WHERE  [IsDeleted] = 0 AND [ReaderGroupID] = " + groupID.ToString();
                    DataSet dsReaders = dbhelper.ExcuteDatset(dbhelper.Command);

                    List<ReaderInfo> readersInfo = DbHelper.DataTableToList<ReaderInfo>(dsReaders.Tables[0]).ToList();
                    rdrGrp.Readers = readersInfo;

                    return rdrGrp;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 获取数据库帮助对象。
        /// </summary>
        /// <param name="database">数据库类型</param>
        /// <param name="host">数据库主机</param>
        /// <param name="instance">数据库实例</param>
        /// <param name="account">账号</param>
        /// <param name="password">密码</param>
        /// <param name="port">端口号</param>
        /// <returns>数据库帮助对象</returns>
        public static DbHelper Create(
            DatabaseType database,
            string host,
            string instance,
            string account,
            string password,
            int? port = null)
        {
            var connectionString = GetConnectionString(database, host, instance, account, password, port);
            var dbHelper = new DbHelper(Providers[(int)database], connectionString);

            switch (database)
            {
                case DatabaseType.MSSQL:
                    dbHelper.DbMetadata = new MSSQLMetadata();

                    break;
                case DatabaseType.Oracle:
                    dbHelper.DbMetadata = new OracleMetadata();

                    break;
            }

            return dbHelper;
        }

        public bool Delete(Where where) {
 
            using (SqlCommand command = new DbHelper().Command) {
                string sql = $"delete from {Table} where {where.Result};";
                return command.ExecuteNonQueryExt(sql, where) > 0;
            }
        }

 public static List<spPharmacyStockCard> GetspPharmacyStockCardList(String[] parameterField, String[] param)
 {
     List<spPharmacyStockCard> result = new List<spPharmacyStockCard>();
     IDbContext ctx = DbFactory.Configure();
     try
     {
         DbHelper helper = new DbHelper(typeof(spPharmacyStockCard));
         ctx.CommandText = "spfmrpt_KartuPersediaanFarmasi";
         ctx.CommandType = System.Data.CommandType.StoredProcedure;
         //Add Parameter
         int count = parameterField.Length;
         for (int i = 0; i < count; i++)
         {
             ctx.Add(parameterField[i], param[i]);
         }
         using (IDataReader reader = DaoBase.GetDataReader(ctx))
             while (reader.Read())
                 result.Add((spPharmacyStockCard)helper.IDataReaderToObject(reader, new spPharmacyStockCard()));
     }
     catch (Exception ex)
     {
         throw new Exception(ex.Message, ex);
     }
     finally
     {
         ctx.Close();
     }
     return result;
 }

        public List<DadosAES> ObterItemAESPorNumeroAES(string numeroAES)
        {
            List<DadosAES> listaAES = new List<DadosAES>();

            DbHelper db = new DbHelper();

            string cmdText = @"select b.Numero_AES, b.Item_AES
                                 from Frequencia4Edicao a, [dbo].[vw_mantida_curso_turma]  b
                                where 1=1
                                  and a.idCursoTurnoTurma = b.idCursoTurnoTurma
                                  and b.Numero_AES = @Numero_AES
                             group by b.Numero_AES, b.Item_AES
                             order by 2";

            db.AddParameter(new System.Data.SqlClient.SqlParameter("@Numero_AES", numeroAES));

            SqlDataReader dr = db.GetDataReader(cmdText);

            if (dr.HasRows)
            {
                while (dr.Read())
                {
                    listaAES.Add(new DadosAES
                    {
                        NumeroAES = dr["Numero_AES"].ToString(),
                        ItemAES = Convert.ToInt32(dr["Item_AES"])
                    });

                }
            }

            db.CloseDbConnection();

            return listaAES;
        }

    protected void Page_Load(object sender, EventArgs e)
    {
        if (Session["uname"] == null)
        {
            Response.Write("<script>alert('系统超时或非法登录，请重新登录！');window.location.href='default.aspx';</script>");
            return;
        }
        if (Session["uid"]==null)
        {
            Response.Write("<script>alert('系统超时或非法登录，请重新登录！');window.location.href='default.aspx';</script>");
            return;
        }

        if (Session["ucount"] == null)
        {
            Response.Write("<script>alert('系统超时或非法登录，请重新登录！');window.location.href='default.aspx';</script>");
            return;
        }
        string uid = Session["uid"].ToString();
        dbh = new DbHelper();
        string sql;
        sql = string.Format("select count(*) from userinfo where parent_id='{0}' ", uid);
        DbCommand dbc = dbh.GetSqlStringCommond(sql);

        int count=int.Parse(dbh.ExecuteScalar(dbc).ToString());

        int usercount = int.Parse(Session["ucount"].ToString()); ;
        if (count >= usercount)
        {
            Response.Write("<script>alert('用户最大数超出设定范围，请联系管理员！');window.location.href='userlist.aspx';</script>");
            return;
        }

        if (Request["id"] != null)
        {

            id = Request["id"];

            sql = string.Format("select * from userinfo where id='{0}' ", Request["id"]);
            DbCommand dbc3 = dbh.GetSqlStringCommond(sql);
            dbr = dbh.ExecuteReader(dbc3);
            dbr.Read();
            tb_guid.Text = dbr["guid"].ToString();
            tb_memo.Text = dbr["memo"].ToString();
            tb_buydate.Text = dbr["buy_date"].ToString();
            tb_stopdate.Text = dbr["stop_date"].ToString();
            tb_username.Text = dbr["user_name"].ToString();
            rb_stop.Checked = dbr["active"].ToString() == "0" ? true : false;
            rb_active.Checked = dbr["active"].ToString() == "0" ? false : true;

        }
        else
        {
            tb_guid.ReadOnly = false;
            tb_buydate.Text = DateTime.Now.ToString("yyyyMMdd");
            tb_stopdate.Text = DateTime.Now.AddYears(1).ToString("yyyyMMdd");
            rb_stop.Checked = true;
        }
    }

 public static Employee findEmployeeById(Guid id, DbHelper helper)
 {
     var query = from e in helper.Employees
                 where e.ID == id
                 select e;
     var em = query.FirstOrDefault();
     return em;
 }

 public static Employee findEmployeeByMail(String mail, DbHelper helper)
 {
     var query = from e in helper.Employees
                 where e.MailAddress == mail
                 select e;
     var em = query.FirstOrDefault();
     return em;
 }

 public static Employee findEmployeeByName(String name, DbHelper helper)
 {
     var query = from e in helper.Employees
                 where e.Name == name
                 select e;
     var em = query.FirstOrDefault();
     return em;
 }

        protected override void getTagSQL()
        {
            tempCreate = "";
            rightsJoin = "";
            this.oper = queryParams.GetValue<int>(SParam.OPERATOR);

            DbHelper db = new DbHelper(conStr, true);
            addSQLInner();
        }

        public frmGenres(DbHelper db, DataRow dr, FormMode mode)
            : base(db, dr, mode)
        {
            InitializeComponent();

            this.Load += frmGenres_Load;
            this.FormClosing += frmGenres_FormClosing;
            this.Shown += frmGenres_Shown;
        }

 /// summary
 /// �������ݿ�洢����
 /// /summary
 /// param name="procedureName"�洢������/param
 /// param name="procedureText"�洢��������/param
 public override void CreateProcedure(string procedureName, string procedureText)
 {
     if(procedureText != null && procedureText.Trim() != "")
     {
         DropProcedure(procedureName);
         DbHelper helper = new DbHelper();
         helper.ExecuteNonQuery(procedureText);
     }
 }

        public frmCinema(DbHelper db)
            : base(db)
        {
            InitializeComponent();

            this.Load += frmCinema_Load;
            this.FormClosing += frmCinema_FormClosing;
            this.Shown += frmCinema_Shown;
        }

 /// summary
 /// �������ݿ⺯��
 /// /summary
 /// param name="functionName"������/param
 /// param name="functionText"��������/param
 public override void CreateFunction(string functionName, string functionText)
 {
     if(functionText != null && functionText.Trim() != "")
     {
         DropFunction(functionName);
         DbHelper helper = new DbHelper();
         helper.ExecuteNonQuery(functionText);
     }
 }

        public bool Insert(User tModel) {
            using (SqlCommand command = new DbHelper().Command) {
                command.CommandText =
                    "insert into eduuser(userid,userpass,name,age,birthday) values (@userid,@userpass,@name,@age,@birthday)";
                command.Parameters.AddRange(CreateSqlParameters(tModel));
                int ret = command.ExecuteNonQuery();

                return ret > 0;
            }
        }

        public bool Insert(User_Model tModel) {
            using (SqlCommand command = new DbHelper().Command) {
                command.CommandText =
                    $"insert into {Table}(UserID,[Password],Name,Sex,Birthday,Email) values (@UserID,@Password,@Name,@Sex,@Birthday,@Email)";
                command.Parameters.AddRange(CreateSqlParameters(tModel));
                int ret = command.ExecuteNonQuery();

                return ret > 0;
            }
        }

	static DbHelper()
	{
        BootStrapServers = new DbHelper<SqlConnection, SqlCommand, SqlParameter>();
        BootStrapServers.ConnectionString = System.Configuration.ConfigurationManager.ConnectionStrings["BootStrapServers"].ConnectionString;

        //OpenService_CDNCooperators = new DbHelper<MySqlConnection, MySqlCommand, MySqlParameter>();
        //OpenService_CDNCooperators.ConnectionString = System.Configuration.ConfigurationManager.ConnectionStrings["OpenService_CDNCooperators"].ConnectionString;

        OpenService_Files = new DbHelper<MySqlConnection, MySqlCommand, MySqlParameter>();
        OpenService_Files.ConnectionString = System.Configuration.ConfigurationManager.ConnectionStrings["OpenService_Files"].ConnectionString;
    }

        public User GetOne(Where @where, string fields) {
            using (SqlCommand command = new DbHelper().Command) {
                User user = new User();
                string sql = $"select top 1 {fields} from {Table} where {where.Result};";
                IDataReader reader = command.ExecuteReaderExt(sql, where);

                if (reader.Read()) {
                    user = ReaderModel(reader, fields);
                }
                return user;
            }
        }

 public AutomaticCluster(ActorSystem system)
 {
     _system = system;
     _cluster = Cluster.Get(system);
     _persistence = SqlitePersistence.Get(system);
     _dbHelper = new DbHelper(() =>
     {
         var conn = new SQLiteConnection(_persistence.DefaultJournalConfig.GetString("connection-string"));
         conn.Open();
         return conn;
     });
 }

 public AutomaticCluster(ActorSystem system)
 {
     _system = system;
     _cluster = Cluster.Get(system);
     _persistence = SqlitePersistence.Get(system);
     _dbHelper = new DbHelper(() =>
     {
         var conn = new SQLiteConnection(_persistence.JournalSettings.ConnectionString);
         conn.Open();
         return conn;
     });
 }