C#-操作PostgreSQL-数据库

2024-05-25 23:32
文章标签 c# 操作 数据库 postgresql .net netcore

本文主要是介绍C#-操作PostgreSQL-数据库，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、第三方类库

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

二、自定义接口及操作类

2.1接口类

public interface 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 操作类

/// <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();da.Fill(ds, "ds");cmd.Parameters.Clear();return ds;}}}}/// <summary>/// 在事务中执行查询，返回DataSet/// </summary>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;}/// <summary>/// 执行 Transact-SQL 语句并返回受影响的行数。/// </summary>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.Parameters.Clear();return val;}}/// <summary>/// 在事务中执行 Transact-SQL 语句并返回受影响的行数。/// </summary>public int ExecuteNonQuery(DbTransaction trans, CommandType cmdType, string cmdText,params DbParameter[] cmdParms){NpgsqlCommand cmd = new NpgsqlCommand();PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);int val = cmd.ExecuteNonQuery();cmd.Parameters.Clear();return val;}/// <summary>/// 执行查询，返回DataReader/// </summary>public DbDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText,params DbParameter[] cmdParms){NpgsqlCommand cmd = new NpgsqlCommand();NpgsqlConnection conn = new NpgsqlConnection(connectionString);try{PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);NpgsqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);cmd.Parameters.Clear();return rdr;}catch{conn.Close();throw;}}/// <summary>/// 在事务中执行查询，返回DataReader/// </summary>public DbDataReader ExecuteReader(DbTransaction trans, CommandType cmdType, string cmdText,params DbParameter[] cmdParms){NpgsqlCommand cmd = new NpgsqlCommand();PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);NpgsqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);cmd.Parameters.Clear();return rdr;}/// <summary>/// 执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。/// </summary>public object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText,params DbParameter[] cmdParms){NpgsqlCommand cmd = new NpgsqlCommand();using (NpgsqlConnection connection = new NpgsqlConnection(connectionString)){PrepareCommand(cmd, connection, null, cmdType, cmdText, cmdParms);object val = cmd.ExecuteScalar();cmd.Parameters.Clear();return val;}}/// <summary>/// 在事务中执行查询，并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。/// </summary>public object ExecuteScalar(DbTransaction trans, CommandType cmdType, string cmdText,params DbParameter[] cmdParms){NpgsqlCommand cmd = new NpgsqlCommand();PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);object val = cmd.ExecuteScalar();cmd.Parameters.Clear();return val;}/// <summary>/// 生成要执行的命令/// </summary>/// <remarks>参数的格式：冒号+参数名</remarks>private static void PrepareCommand(DbCommand cmd, DbConnection conn, DbTransaction trans, CommandType cmdType,string cmdText, DbParameter[] cmdParms){if (conn.State != ConnectionState.Open)conn.Open();cmd.Connection = conn;cmd.CommandText = cmdText.Replace("@", ":").Replace("?", ":").Replace("[", "\"").Replace("]", "\"");if (trans != null)cmd.Transaction = trans;cmd.CommandType = cmdType;if (cmdParms != null){foreach (NpgsqlParameter parm in cmdParms){parm.ParameterName = parm.ParameterName.Replace("@", ":").Replace("?",":");cmd.Parameters.Add(parm);}}}}

三、数据库操作实例

写入实例：

IDBHelper dbHelper = new PostgreHelper();
string connectionString = "User ID=postgres;Password=admin;Server=192.168.0.226;Port=5432;Database=MonitorDB;";
string sql = "insert into [RawLog]([ProjectID],[File],[Note]) values('项目编号',@file,'备注')";string file = this.textBox1.Text;
if (!File.Exists(file)) return;//获取文件二进制流
System.IO.FileStream fs = new System.IO.FileStream(file, System.IO.FileMode.Open);
BinaryReader br = new BinaryReader(fs);
byte[] b = br.ReadBytes((int)fs.Length);
br.Close();fs.Close();int r = dbHelper.ExecuteNonQuery(connectionString, CommandType.Text,sql,new Npgsql.NpgsqlParameter("@file",raw_log.File));

注意：

1.查询语句中表名、字段名需用中括号[ ] 封起来，在操作类中会统一替换为双引号。

2.命令语句中的参数名格式为：@或？+ 参数名，在操作类中为统一替换为冒号。

3.对于二进制流、日期等特殊类型需采用2中的参数形式

4.经多次测试postgreSQL数据库只直接支持（冒号+参数名）的参数方式


这篇关于C#-操作PostgreSQL-数据库的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1002921。

相关文章

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式

《Java通过驱动包(jar包)连接MySQL数据库的步骤总结及验证方式》本文详细介绍如何使用Java通过JDBC连接MySQL数据库,包括下载驱动、配置Eclipse环境、检测数据库连接等关键步骤,... 目录一、下载驱动包二、放jar包三、检测数据库连接JavaJava 如何使用 JDBC 连接 mys
阅读更多...
Java操作Word文档的全面指南

Java操作Word文档的全面指南

《Java操作Word文档的全面指南》在Java开发中,操作Word文档是常见的业务需求,广泛应用于合同生成、报表输出、通知发布、法律文书生成、病历模板填写等场景,本文将全面介绍Java操作Word文... 目录简介段落页头与页脚页码表格图片批注文本框目录图表简介Word编程最重要的类是org.apach
阅读更多...
C#读写文本文件的多种方式详解

C#读写文本文件的多种方式详解

《C#读写文本文件的多种方式详解》这篇文章主要为大家详细介绍了C#中各种常用的文件读写方式,包括文本文件,二进制文件、CSV文件、JSON文件等,有需要的小伙伴可以参考一下... 目录一、文本文件读写1. 使用 File 类的静态方法2. 使用 StreamReader 和 StreamWriter二、二进
阅读更多...
C#中Guid类使用小结

C#中Guid类使用小结

《C#中Guid类使用小结》本文主要介绍了C#中Guid类用于生成和操作128位的唯一标识符,用于数据库主键及分布式系统,支持通过NewGuid、Parse等方法生成,感兴趣的可以了解一下... 目录前言一、什么是 Guid二、生成 Guid1. 使用 Guid.NewGuid() 方法2. 从字符串创建
阅读更多...
PostgreSQL的扩展dict_int应用案例解析

PostgreSQL的扩展dict_int应用案例解析

《PostgreSQL的扩展dict_int应用案例解析》dict_int扩展为PostgreSQL提供了专业的整数文本处理能力,特别适合需要精确处理数字内容的搜索场景,本文给大家介绍PostgreS... 目录PostgreSQL的扩展dict_int一、扩展概述二、核心功能三、安装与启用四、字典配置方法
阅读更多...
C# 比较两个list 之间元素差异的常用方法

C# 比较两个list 之间元素差异的常用方法

《C#比较两个list之间元素差异的常用方法》：本文主要介绍C#比较两个list之间元素差异,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1. 使用Except方法2. 使用Except的逆操作3. 使用LINQ的Join,GroupJoin
阅读更多...
Python实现对阿里云OSS对象存储的操作详解

Python实现对阿里云OSS对象存储的操作详解

《Python实现对阿里云OSS对象存储的操作详解》这篇文章主要为大家详细介绍了Python实现对阿里云OSS对象存储的操作相关知识,包括连接,上传,下载,列举等功能,感兴趣的小伙伴可以了解下... 目录一、直接使用代码二、详细使用1. 环境准备2. 初始化配置3. bucket配置创建4. 文件上传到os
阅读更多...
mysql表操作与查询功能详解

mysql表操作与查询功能详解

《mysql表操作与查询功能详解》本文系统讲解MySQL表操作与查询,涵盖创建、修改、复制表语法,基本查询结构及WHERE、GROUPBY等子句,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随... 目录01.表的操作1.1表操作概览1.2创建表1.3修改表1.4复制表02.基本查询操作2.1 SE
阅读更多...
MySQL数据库中ENUM的用法是什么详解

MySQL数据库中ENUM的用法是什么详解

《MySQL数据库中ENUM的用法是什么详解》ENUM是一个字符串对象,用于指定一组预定义的值,并可在创建表时使用,下面：本文主要介绍MySQL数据库中ENUM的用法是什么的相关资料,文中通过代码... 目录mysql 中 ENUM 的用法一、ENUM 的定义与语法二、ENUM 的特点三、ENUM 的用法1
阅读更多...
Java中调用数据库存储过程的示例代码

Java中调用数据库存储过程的示例代码

《Java中调用数据库存储过程的示例代码》本文介绍Java通过JDBC调用数据库存储过程的方法,涵盖参数类型、执行步骤及数据库差异,需注意异常处理与资源管理,以优化性能并实现复杂业务逻辑,感兴趣的朋友... 目录一、存储过程概述二、Java调用存储过程的基本javascript步骤三、Java调用存储过程示
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2