一、第三方类库 Npgsql提供 .NET 操作postgreSQL数据库的相关类。支持postgreSQL7.x 及以上版本。 二、自定义接口及操作类 2.1接口类 public interface IDBHelper { /// summary /// 执行 Transact-SQL 语句并返回受影响的行数。 /// /summary int ExecuteNo
一、第三方类库
Npgsql提供 .NET 操作postgreSQL数据库的相关类。支持postgreSQL7.x 及以上版本。
二、自定义接口及操作类
2.1接口类
public interface IDBHelper
{
///
/// 执行 Transact-SQL 语句并返回受影响的行数。
///
int ExecuteNonQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 在事务中执行 Transact-SQL 语句并返回受影响的行数。
///
int ExecuteNonQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 在事务中执行查询，返回DataSet
///
DataSet ExecuteQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 执行查询，返回DataSet
///
DataSet ExecuteQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 在事务中执行查询，返回DataReader
///
DbDataReader ExecuteReader(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 执行查询，返回DataReader
///
DbDataReader ExecuteReader(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 在事务中执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。
///
object ExecuteScalar(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。
///
object ExecuteScalar(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);
///
/// 得到数据条数
///
/// 表名
/// 条件(不需要where)
///
int GetCount(string connectionString, string tblName, string condition);
}
2.2 操作类
///
/// 数据库操作基类(for PostgreSQL)
///
public class PostgreHelper : PageHelper, IDBHelper
{
///
/// 分页获取数据
///
/// 连接字符串
/// 表名
/// 字段名
/// 页大小
/// 第几页
/// 排序字段
/// 升序{False}/降序(True)
/// 条件(不需要where)
public DbDataReader GetPageList(string connectionString, string tblName, int pageSize,
int pageIndex, string fldSort, bool sort, string condition)
{
string sql = GetPagerSQL(condition, pageSize, pageIndex, fldSort, tblName, sort);
return ExecuteReader(connectionString, CommandType.Text, sql, null);
}
///
/// 得到数据条数
///
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());
}
///
/// 执行查询，返回DataSet
///
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();
da.Fill(ds, "ds");
cmd.Parameters.Clear();
return ds;
}
}
}
}
///
/// 在事务中执行查询，返回DataSet
///
public DataSet ExecuteQuery(DbTransaction trans, CommandType cmdType, string cmdText,
params DbParameter[] cmdParms)
{
NpgsqlCommand cmd = new NpgsqlCommand();
PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);
NpgsqlDataAdapter da = new NpgsqlDataAdapter(cmd);
DataSet ds = new DataSet();
da.Fill(ds, "ds");
cmd.Parameters.Clear();
return ds;
}
///
/// 执行 Transact-SQL 语句并返回受影响的行数。
///
public int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText,
params DbParameter[] cmdParms)
{
NpgsqlCommand cmd = new NpgsqlCommand();
using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
cmd.Parameter