当前位置:数据库 > SQLServer >>

C# 操作PostgreSQL 数据库

一、第三方类库

Npgsql提供 .NET 操作postgreSQL数据库的相关类。支持postgreSQL7.x 及以上版本。

二、自定义接口及操作类

2.1接口类

[csharp] 
public inte易做图ce IDBHelper 
    { 
        /// <summary> 
        /// 执行 Transact-SQL 语句并返回受影响的行数。 
        /// </summary> 
        int ExecuteNonQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 在事务中执行 Transact-SQL 语句并返回受影响的行数。 
        /// </summary> 
        int ExecuteNonQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 在事务中执行查询,返回DataSet 
        /// </summary> 
        DataSet ExecuteQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 执行查询,返回DataSet 
        /// </summary> 
        DataSet ExecuteQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 在事务中执行查询,返回DataReader 
        /// </summary> 
        DbDataReader ExecuteReader(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 执行查询,返回DataReader 
        /// </summary> 
        DbDataReader ExecuteReader(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 在事务中执行查询,并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。 
        /// </summary> 
        object ExecuteScalar(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 执行查询,并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。 
        /// </summary> 
        object ExecuteScalar(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms); 
 
        /// <summary> 
        /// 得到数据条数 
        /// </summary> 
        /// <param name="tblName">表名</param> 
        /// <param name="condition">条件(不需要where)</param> 
        /// <returns>数据条数</returns> 
        int GetCount(string connectionString, string tblName, string condition); 
    } 

2.2 操作类

[csharp]
/// <summary> 
    /// 数据库操作基类(for PostgreSQL) 
    /// </summary> 
    public class PostgreHelper : IDBHelper 
    { 
        /// <summary> 
        /// 得到数据条数 
        /// </summary> 
        public int GetCount(string connectionString, string tblName, string condition) 
        { 
            StringBuilder sql = new StringBuilder("select count(*) from " + tblName); 
            if (!string.IsNullOrEmpty(condition)) 
                sql.Append(" where " + condition); 
 
            object count = ExecuteScalar(connectionString, CommandType.Text, sql.ToString(), null); 
            return int.Parse(count.ToString()); 
        } 
 
        /// <summary> 
        /// 执行查询,返回DataSet 
        /// </summary> 
        public DataSet ExecuteQuery(string connectionString, CommandType cmdType, string cmdText, 
            params DbParameter[] cmdParms) 
        { 
            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString)) 
            { 
                using (NpgsqlCommand cmd = new NpgsqlCommand()) 
                { 
                    PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 
                    using (NpgsqlDataAdapter da = new NpgsqlDataAdapter(cmd)) 
                    { 
                        DataSet ds = new DataSet(); 

补充:软件开发 , C# ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,