BB猫!
返回

MySqlHelper

2022-12-06 810 0

    public class MySqlHelper
    {
        public string connstr;//= "server=localhost;uid=root;pwd=root;database=zf8p;pooling=false";
        public MySqlConnection CreateConnection()
        {
            MySqlConnection conn = new MySqlConnection(connstr);
            conn.Open();
            return conn;
        }
        public int ExecuteNonQuery(string sql, params MySqlParameter[] parameters)
        {
            using (MySqlConnection conn = CreateConnection())
            using (MySqlCommand cmd = conn.CreateCommand())
            {
                cmd.CommandText = sql;
                cmd.Parameters.AddRange(parameters);
                return cmd.ExecuteNonQuery();
            }
        }
        public object ExecuteScalar(string sql, params MySqlParameter[] parameters)
        {
            using (MySqlConnection conn = CreateConnection())
            using (MySqlCommand cmd = conn.CreateCommand())
            {
                cmd.CommandText = sql;
                cmd.Parameters.AddRange(parameters);
                return cmd.ExecuteScalar();
            }
        }
        public MySqlDataReader ExecuteReader(string sql, params MySqlParameter[] ps)
        {
            using (MySqlConnection conn = CreateConnection())
            using (MySqlCommand cmd = conn.CreateCommand())
            {
                cmd.CommandText = sql;
                if (ps != null)
                {
                    cmd.Parameters.AddRange(ps);
                }
                return cmd.ExecuteReader();
            }
        }
        public DataTable ExecuteDataTable(string sql, params MySqlParameter[] ps)
        {
            DataTable table = new DataTable();
            using (MySqlConnection conn = CreateConnection())
            using (MySqlCommand cmd = conn.CreateCommand())
            {
                cmd.CommandText = sql;
                if (ps != null)
                {
                    cmd.Parameters.AddRange(ps);
                }
                using (MySqlDataAdapter adapter = new MySqlDataAdapter(cmd))
                {
                    adapter.Fill(table);
                }
                return table;
            }
        }
    }


点赞 收藏

顶部