C# 訪問PostgreSQL 數據庫

時間  2019-12-05 標籤 c# 訪問 postgresql 數據庫

 C# 訪問PostgreSQL 數據庫
sql

1、第三方類庫數據庫

Npgsql提供 .NET 操做postgreSQL數據庫的相關類。支持postgreSQL7.x 及以上版本。ide

2、自定義接口及操做類post

2.1接口類測試

[csharp]  view plain copy
  1. public interface IDBHelper  
  2.     {  
  3.         /// <summary>  
  4.         /// 執行 Transact-SQL 語句並返回受影響的行數。  
  5.         /// </summary>  
  6.         int ExecuteNonQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  7.   
  8.         /// <summary>  
  9.         /// 在事務中執行 Transact-SQL 語句並返回受影響的行數。  
  10.         /// </summary>  
  11.         int ExecuteNonQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  12.   
  13.         /// <summary>  
  14.         /// 在事務中執行查詢，返回DataSet  
  15.         /// </summary>  
  16.         DataSet ExecuteQuery(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  17.   
  18.         /// <summary>  
  19.         /// 執行查詢，返回DataSet  
  20.         /// </summary>  
  21.         DataSet ExecuteQuery(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  22.   
  23.         /// <summary>  
  24.         /// 在事務中執行查詢，返回DataReader  
  25.         /// </summary>  
  26.         DbDataReader ExecuteReader(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  27.   
  28.         /// <summary>  
  29.         /// 執行查詢，返回DataReader  
  30.         /// </summary>  
  31.         DbDataReader ExecuteReader(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  32.   
  33.         /// <summary>  
  34.         /// 在事務中執行查詢，並返回查詢所返回的結果集中第一行的第一列。忽略其餘列或行。  
  35.         /// </summary>  
  36.         object ExecuteScalar(System.Data.Common.DbTransaction trans, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  37.   
  38.         /// <summary>  
  39.         /// 執行查詢，並返回查詢所返回的結果集中第一行的第一列。忽略其餘列或行。  
  40.         /// </summary>  
  41.         object ExecuteScalar(string connectionString, System.Data.CommandType cmdType, string cmdText, params System.Data.Common.DbParameter[] cmdParms);  
  42.   
  43.         /// <summary>  
  44.         /// 獲得數據條數  
  45.         /// </summary>  
  46.         /// <param name="tblName">表名</param>  
  47.         /// <param name="condition">條件(不須要where)</param>  
  48.         /// <returns>數據條數</returns>  
  49.         int GetCount(string connectionString, string tblName, string condition);  
  50.     }  

2.2 操做類ui

[csharp]  view plain copy
  1. /// <summary>  
  2.     /// 數據庫操做基類(for PostgreSQL)  
  3.     /// </summary>  
  4.     public class PostgreHelper : IDBHelper  
  5.     {  
  6.         /// <summary>  
  7.         /// 獲得數據條數  
  8.         /// </summary>  
  9.         public int GetCount(string connectionString, string tblName, string condition)  
  10.         {  
  11.             StringBuilder sql = new StringBuilder("select count(*) from " + tblName);  
  12.             if (!string.IsNullOrEmpty(condition))  
  13.                 sql.Append(" where " + condition);  
  14.   
  15.             object count = ExecuteScalar(connectionString, CommandType.Text, sql.ToString(), null);  
  16.             return int.Parse(count.ToString());  
  17.         }  
  18.   
  19.         /// <summary>  
  20.         /// 執行查詢，返回DataSet  
  21.         /// </summary>  
  22.         public DataSet ExecuteQuery(string connectionString, CommandType cmdType, string cmdText,  
  23.             params DbParameter[] cmdParms)  
  24.         {  
  25.             using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))  
  26.             {  
  27.                 using (NpgsqlCommand cmd = new NpgsqlCommand())  
  28.                 {  
  29.                     PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);  
  30.                     using (NpgsqlDataAdapter da = new NpgsqlDataAdapter(cmd))  
  31.                     {  
  32.                         DataSet ds = new DataSet();  
  33.                         da.Fill(ds, "ds");  
  34.                         cmd.Parameters.Clear();  
  35.                         return ds;  
  36.                     }  
  37.                 }  
  38.             }  
  39.         }  
  40.   
  41.         /// <summary>  
  42.         /// 在事務中執行查詢，返回DataSet  
  43.         /// </summary>  
  44.         public DataSet ExecuteQuery(DbTransaction trans, CommandType cmdType, string cmdText,  
  45.             params DbParameter[] cmdParms)  
  46.         {  
  47.             NpgsqlCommand cmd = new NpgsqlCommand();  
  48.             PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);  
  49.             NpgsqlDataAdapter da = new NpgsqlDataAdapter(cmd);  
  50.             DataSet ds = new DataSet();  
  51.             da.Fill(ds, "ds");  
  52.             cmd.Parameters.Clear();  
  53.             return ds;  
  54.         }  
  55.   
  56.         /// <summary>  
  57.         /// 執行 Transact-SQL 語句並返回受影響的行數。  
  58.         /// </summary>  
  59.         public int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText,  
  60.             params DbParameter[] cmdParms)  
  61.         {  
  62.             NpgsqlCommand cmd = new NpgsqlCommand();  
  63.   
  64.             using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))  
  65.             {  
  66.                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);  
  67.                 int val = cmd.ExecuteNonQuery();  
  68.                 cmd.Parameters.Clear();  
  69.                 return val;  
  70.             }  
  71.         }  
  72.   
  73.         /// <summary>  
  74.         /// 在事務中執行 Transact-SQL 語句並返回受影響的行數。  
  75.         /// </summary>  
  76.         public int ExecuteNonQuery(DbTransaction trans, CommandType cmdType, string cmdText,  
  77.             params DbParameter[] cmdParms)  
  78.         {  
  79.             NpgsqlCommand cmd = new NpgsqlCommand();  
  80.             PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);  
  81.             int val = cmd.ExecuteNonQuery();  
  82.             cmd.Parameters.Clear();  
  83.             return val;  
  84.         }  
  85.   
  86.         /// <summary>  
  87.         /// 執行查詢，返回DataReader  
  88.         /// </summary>  
  89.         public DbDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText,  
  90.             params DbParameter[] cmdParms)  
  91.         {  
  92.             NpgsqlCommand cmd = new NpgsqlCommand();  
  93.             NpgsqlConnection conn = new NpgsqlConnection(connectionString);  
  94.   
  95.             try  
  96.             {  
  97.                 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms);  
  98.                 NpgsqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);  
  99.                 cmd.Parameters.Clear();  
  100.                 return rdr;  
  101.             }  
  102.             catch  
  103.             {  
  104.                 conn.Close();  
  105.                 throw;  
  106.             }  
  107.         }  
  108.   
  109.         /// <summary>  
  110.         /// 在事務中執行查詢，返回DataReader  
  111.         /// </summary>  
  112.         public DbDataReader ExecuteReader(DbTransaction trans, CommandType cmdType, string cmdText,  
  113.             params DbParameter[] cmdParms)  
  114.         {  
  115.             NpgsqlCommand cmd = new NpgsqlCommand();  
  116.             PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);  
  117.             NpgsqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);  
  118.             cmd.Parameters.Clear();  
  119.             return rdr;  
  120.         }  
  121.   
  122.         /// <summary>  
  123.         /// 執行查詢，並返回查詢所返回的結果集中第一行的第一列。忽略其餘列或行。  
  124.         /// </summary>  
  125.         public object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText,  
  126.             params DbParameter[] cmdParms)  
  127.         {  
  128.             NpgsqlCommand cmd = new NpgsqlCommand();  
  129.   
  130.             using (NpgsqlConnection connection = new NpgsqlConnection(connectionString))  
  131.             {  
  132.                 PrepareCommand(cmd, connection, null, cmdType, cmdText, cmdParms);  
  133.                 object val = cmd.ExecuteScalar();  
  134.                 cmd.Parameters.Clear();  
  135.                 return val;  
  136.             }  
  137.         }  
  138.   
  139.         /// <summary>  
  140.         /// 在事務中執行查詢，並返回查詢所返回的結果集中第一行的第一列。忽略其餘列或行。  
  141.         /// </summary>  
  142.         public object ExecuteScalar(DbTransaction trans, CommandType cmdType, string cmdText,  
  143.             params DbParameter[] cmdParms)  
  144.         {  
  145.             NpgsqlCommand cmd = new NpgsqlCommand();  
  146.             PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms);  
  147.             object val = cmd.ExecuteScalar();  
  148.             cmd.Parameters.Clear();  
  149.             return val;  
  150.         }  
  151.   
  152.         /// <summary>  
  153.         /// 生成要執行的命令  
  154.         /// </summary>  
  155.         /// <remarks>參數的格式：冒號+參數名</remarks>  
  156.         private static void PrepareCommand(DbCommand cmd, DbConnection conn, DbTransaction trans, CommandType cmdType,  
  157.             string cmdText, DbParameter[] cmdParms)  
  158.         {  
  159.             if (conn.State != ConnectionState.Open)  
  160.                 conn.Open();  
  161.   
  162.             cmd.Connection = conn;  
  163.             cmd.CommandText = cmdText.Replace("@", ":").Replace("?", ":").Replace("[", "\"").Replace("]", "\"");  
  164.   
  165.             if (trans != null)  
  166.                 cmd.Transaction = trans;  
  167.   
  168.             cmd.CommandType = cmdType;  
  169.   
  170.             if (cmdParms != null)  
  171.             {  
  172.                 foreach (NpgsqlParameter parm in cmdParms)  
  173.                 {  
  174.                     parm.ParameterName = parm.ParameterName.Replace("@", ":").Replace("?",":");  
  175.   
  176.                     cmd.Parameters.Add(parm);  
  177.                 }  
  178.             }  
  179.         }  
  180.     }  

3、數據庫操做實例

寫入實例：this

[csharp]  view plain copy
  1. IDBHelper dbHelper = new PostgreHelper();  
  2. string connectionString = "User ID=postgres;Password=admin;Server=192.168.0.226;Port=5432;Database=MonitorDB;";  
  3. string sql = "insert into [RawLog]([ProjectID],[File],[Note]) values('項目編號',@file,'備註')";  
  4.   
  5. string file = this.textBox1.Text;  
  6. if (!File.Exists(file)) return;  
  7.   
  8. //獲取文件二進制流  
  9. System.IO.FileStream fs = new System.IO.FileStream(file, System.IO.FileMode.Open);  
  10. BinaryReader br = new BinaryReader(fs);  
  11. byte[] b = br.ReadBytes((int)fs.Length);  
  12. br.Close();fs.Close();  
  13.   
  14. int r = dbHelper.ExecuteNonQuery(connectionString, CommandType.Text,sql,new Npgsql.NpgsqlParameter("@file",raw_log.File));  


注意：

1.查詢語句中表名、字段名需用中括號[ ] 封起來，在操做類中會統一替換爲雙引號。spa

2.命令語句中的參數名格式爲：@或？+ 參數名，在操做類中爲統一替換爲冒號。
.net

3.對於二進制流、日期等特殊類型需採用2中的參數形式postgresql

4.經屢次測試postgreSQL數據庫只直接支持（冒號+參數名）的參數方式

联系我们 沪ICP备2021010478号-7