程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#基礎知識 >> C#訪問PostGreSQL數據庫的方法

C#訪問PostGreSQL數據庫的方法

編輯:C#基礎知識

我對PostGreSQL只是一知半解,記錄這個過程是希望如果以後微軟技術方向的人遇到類似的需求,可以有個比較直接的的參考。
在不熟悉的知識領域裡,總是有搜索引擎可以幫到我。

初步了解PostGreSQL數據庫及數據形態

首先我想看看PostGreSQL的數據庫以及我想要獲取的數據形態是什麼樣子的,Linux和PostGreSQL這兩個關鍵字我都不熟悉,搜了一下找到了一個可以連通PostGreSQL數據庫的Windows客戶端,叫pgAdmin,我裝的是III版本,應該是比較新的,下載安裝後看到界面:

點擊那個電源插頭的logo可以新建服務器連接

名稱就是在PGAdmin客戶端的顯示名,可以自定義。
SSL呢,有這麼多選項,我不是很了解干什麼用的,反正我選的允許。

端口號,默認PostGreSQL的端口號是5432,當然可以被修改,自定義成別的端口號
全部填寫完點擊確定,就可以看到數據庫了。
我不在客戶現場,連不上PostGreSQL的庫,所以下面就不能截圖了。

在PGAdmin裡,可以寫查詢語句,如果你有權限的話,可以看到返回的結果集。
我點開一個窗口,試著寫了一條查詢語句如下:
Select top 10 * from TableObj
執行,發現結果集窗口提示語法錯誤,問下群裡的兄弟們,得知,正確的寫法應該是這樣的:
Select * from TableObj limit 5
語法規則跟sql語句還是有區別的。
執行,提示找不到對象“TableObj”找到TableObj的上一層容器“ContainerObj”,修改如下
SELECT* FROM ContainerObj.TableObj limit 5
點擊執行,終於看到了結果集。
相對sqlserver來說,PGAdmin的結果集顯示界面表頭都有兩行,一行是字段名,一行是字段的數據類型。這點很有愛。
在PostGreSQL的查詢語句中,大小寫是不敏感的。
關於PostgreSql語法規則,在CSDN上找到了《PostgreSql語法詳細手冊》,不過這家伙要三個資源分。
好了看到PostGreSQL數據庫了,下面我要嘗試敲C#代碼測試去取PostGreSQL的數據。
C#連接PostGreSQL數據庫

有個東東,叫Npgsql,是PostgreSQL的一個.NET數據提供程序。首先需要下載它,實際上我們只需要引用兩個dll:

經過我的測試,如果只引用了Npgsql.dll,那麼你的程序運行起來之後會報錯,提示找不到對Mono.Security.dll引用的依賴項。
引用了這兩個dll,你還需要在你的代碼中加上using。
using Npgsql;
代碼就很簡單了。
寫了個拼字符串的,比較二。txt什麼什麼的都是Winform的textbox
代碼如下:

///
/// 根據填寫的信息拼數據庫連接串
///
/// 數據庫連接串
private string getConnectStr()
{
   StringBuilder sb = new StringBuilder();
   string str = string.Empty;
   sb.Append("Server=");
   sb.Append(txtServer.Text);
   sb.Append(";Port=");
   sb.Append(txtPort.Text);
   sb.Append(";User Id=");
   sb.Append(txtUID.Text);
   sb.Append(";Password=");
   sb.Append(txtPassword.Text);
   sb.Append(";Database=");
   sb.Append(txtDB.Text);
   sb.Append(";");
   str = sb.ToString();
   return str;
}

實際上數據庫連接串就是這麼樣的一個格式
代碼如下:

"Server=192.168.1.100;Port=5432;UserId=mike;Password=secret;Database=mikedb;"

///
/// 測試連接PostGreSQL數據庫
///
/// Success/Failure
private string TestConnection()
{
   string str = getConnectStr();
   string strMessage = string.Empty;
   try

   {
       NpgsqlConnection conn = new NpgsqlConnection(str);
       conn.Open();
       strMessage = "Success";
       conn.Close();
   }
   catch
   {
       strMessage = "Failure";
   }
   return strMessage;
}

///
/// 測試獲取數據(使用要加try、catch)
///
private void TestGetData()
{
   IDbConnection dbcon;
   dbcon = newNpgsqlConnection(getConnectStr());
   dbcon.Open();
   IDbCommand dbcmd = dbcon.CreateCommand();
   dbcmd.CommandText = " SELECT * FROM ContainerObj.TableObj limit 5";
   IDataReader dr = dbcmd.ExecuteReader();
   string strResult = string.Empty;
   while (dr.Read())
   {
       stringstrRecord_Time_Int = dr[0].ToString();
       stringstrIP = dr[1].ToString();
       stringstrFullPath = dr[2].ToString();
       stringstrUpload_Size = dr[3].ToString();
       stringstrDownLoad_Size = dr[4].ToString();
       strResult += "record_time_int: " + strRecord_Time_Int+ " | ip:" + strIP + " | fullpath:" +strFullPath + " | upload_size:" +strUpload_Size + " | download_size:"+ strDownLoad_Size + "\n";
   }
   dr.Close();
    dr = null;
   lblRes.Text = strResult;
}

Form很簡單,只為測試功能。下面截圖是之前在現場截的,處理了一下,隱去了一些信息。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved