C# PGSQL 關於SQL參數的例示

工作關系 同時使用SQL SERVER 與Postgresql 數據庫，

            clientChar = txtClientChar.Text.Trim();
            sql = "select client_id,client_code,name,client_level_id,client_custom_options_ids, area_id,location ";
            sql += " from client where client_code = @pClient_Code or name like @pName";
            NpgsqlParameter[] sqlPara = new NpgsqlParameter[2];
            //pgsql 的參數與SQL SERVER 的格式不一樣
            sqlPara[0] = new NpgsqlParameter("@pClient_Code", NpgsqlTypes.NpgsqlDbType.Text,20);
            sqlPara[0].Value = clientChar;
            sqlPara[1] = new NpgsqlParameter("@pName", NpgsqlTypes.NpgsqlDbType.Text,100);
            sqlPara[1].Value = '%' + clientChar + '%';
            DataTable dt = DBHelperPg.ExecuteDataTable(sql, sqlPara);
            dataGridView1.DataSource = dt;

附：DBHelperpg.cs

 class DBHelperPg
    {

        public static string ConnectionString = ConfigurationManager.AppSettings["postgre"].ToString();


        /// <summary>  
        /// 執行SQL語句  
        /// </summary>  
        /// <param name="sql">SQL</param>  
        /// <returns>成功返回大於0的數字</returns>  
        public static int ExecuteSQL(string sql)
        {
            int num2 = -1;
            using (NpgsqlConnection connection = new NpgsqlConnection(ConnectionString))
            {
                using (NpgsqlCommand command = new NpgsqlCommand(sql, connection))
                {
                    try
                    {
                        connection.Open();
                        num2 = command.ExecuteNonQuery();
                    }
                    catch (NpgsqlException exception)
                    {
                        throw new Exception(exception.Message);
                    }
                    finally
                    {
                        connection.Close();
                    }
                }
            }
            return num2;
        }

        //帶參數的執行查詢，不返回結果，返回影響行數
        //執行SQL語句並返回受影響的行數
        public static int ExecuteNonQuery(string sql, params NpgsqlParameter[] parameters)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(ConnectionString))
            {
                conn.Open();
                using (NpgsqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    //foreach (SqlParameter param in parameters)
                    //{
                    //    cmd.Parameters.Add(param);
                    //}
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteNonQuery();
                }
            }
        }

        //執行查詢，並返回查詢所返回的結果集中第一行的第一列。忽略額外的列或行。
        public static object ExecuteScalar(string sql, params NpgsqlParameter[] parameters)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(ConnectionString))
            {
                conn.Open();
                using (NpgsqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);
                    return cmd.ExecuteScalar();

                }
            }
        }




        //查詢並返回結果集DataTable,一般只用來執行查詢結果比較少的sql。
        public static DataTable ExecuteDataTable(string sql, params NpgsqlParameter[] parameters)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(ConnectionString))
            {
                conn.Open();
                using (NpgsqlCommand cmd = conn.CreateCommand())
                {
                    cmd.CommandText = sql;
                    cmd.Parameters.AddRange(parameters);

                    NpgsqlDataAdapter adapter = new NpgsqlDataAdapter(cmd);
                    DataSet dataset = new DataSet();
                    adapter.Fill(dataset);
                    return dataset.Tables[0];
                }
            }

            //查詢較大的數據用 DateRead()，但應盡可能用分頁數據，仍然用datatable更好。
        }
    }