PDF.NET資料開發框架實體類操作例項（for PostgreSQL，並且解決自增問題） PDF.NET資料開發框架實體類操作例項（MySQL）
阿新 • • 發佈：2022-04-29
本篇是
PDF.NET資料開發框架實體類操作例項（MySQL）
的姊妹篇，兩者使用了同一個測試程式，不同的只是使用的類庫和資料庫不同，下面說說具體的使用過程。
1，首先在App.config檔案中配置資料庫連線字串：
<?xml version="1.0" encoding="utf-8" ?> <configuration> <connectionStrings> <!--<add name ="default" connectionString ="server=192.168.50.XX;User Id=root;password=XXXX;database=test" providerName="PWMIS.DataProvider.Data.MySQL,PWMIS.MySqlClient"/>--> <add name ="default" connectionString ="server=127.0.0.1;User Id=postgres;password=XXXX;database=Test" providerName="PWMIS.DataProvider.Data.PostgreSQL,PWMIS.PostgreSQLClient"/> </connectionStrings> </configuration>
2，定義一個使用者實體類：
/* * PDF.NET 資料開發框架 * http://www.pwmis.com/sqlmap */ using System; using System.Collections.Generic; using System.Linq; using System.Text; using PWMIS.DataMap.Entity; namespace TestMySqlEntity { class User:EntityBase { public User() { TableName = "tb_user"; PrimaryKeys.Add("ID");//主鍵 IdentityName = "ID";//標識，自增 PropertyNames = new string[] {"ID","Name","Age" }; PropertyValues = new object[PropertyNames.Length]; } public int ID { get { return getProperty<int>("ID"); } set { setProperty("ID", value); } } public int Age { get { return getProperty<int>("Age"); } set { setProperty("Age", value); } } public string Name { get { return getProperty<string>("Name"); } set { setProperty("Name", value,50); } } } }
與MySQL中定義的使用者實體類不同，下面這一行程式碼被註釋掉了：
//IdentityName = "ID";//標識，自增 雖然PostgreSQL有“自增”列，但無法直接取到剛插入的這個自增值，所以需要註釋它。
注：在PDF.NET SOD框架 5.6.0.1121 之後，框架取消了這一個限制，你仍然可以像在其它資料庫中那樣使用PostgreSQL的自增列，實體類無需做任何更改。
3，根據這個實體類，我們去PostgreSQL定義一個使用者表：tb_user，具體過程省略，注意欄位“ID”仍然使用自增列（在PostgreSQL中是 serial 型別，但編輯表型別的時候，發現欄位是整數型別，不過有了預設值：nextval('"User_ID_seq"'::regclass)）。
再定義一個儲存過程查詢指定條件的使用者記錄：
CREATE OR REPLACE FUNCTION "fn_queryUser2"("Age" integer)
RETURNS SETOF tb_user AS
'select * from tb_user where "Age">$1'
LANGUAGE sql VOLATILE
COST 100
ROWS 1000;
ALTER FUNCTION "fn_queryUser2"(integer) OWNER TO postgres;4，編寫ORM實體類操作的測試程式碼：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using PWMIS.DataMap.Entity;
using System.Data;
namespace TestMySqlEntity
{
class Program
{
static void Main(string[] args)
{
PWMIS.DataProvider.Data.AdoHelper db = PWMIS.DataProvider.Adapter.MyDB.GetDBHelperByConnectionName("default");
//PWMIS.DataProvider.Data.AdoHelper db = PWMIS.DataProvider.Adapter.MyDB.Instance ;
//MySQL 儲存過程測試;
//引數名字可以加 @符號，例如 @pAge1
//DataSet ds1 = db.ExecuteDataSet("proc_user1",
// CommandType.StoredProcedure,
// new System.Data.IDataParameter[] { db.GetParameter("@pAge1", 18) });
//PostgreSQL 的儲存過程只管引數順序，不管引數名，如果儲存過程名稱有大寫字母，需要使用雙引號
//fn_queryUser2 定義的引數名字是 Age
DataSet ds1 = db.ExecuteDataSet("[fn_queryUser2]",
CommandType.StoredProcedure,
new System.Data.IDataParameter[] { db.GetParameter("@pAge1", 18) });
//
User u = new User();
//*************構建 OQL 查詢表示式 ******* begin ************
//查詢實體集合
//使用 OQLCompare 物件作為條件
//OQL q = OQL.From(u).Select().Where(new OQLCompare(u).Comparer(u.Age, OQLCompare.CompareType.NoSmaller, 15)).END ;
OQL q = new OQL(u);
//使用OQL2 作為條件物件
q.Select().Where(q.Condition.AND(u.Age, ">=", 15)).OrderBy (u.Age ,"asc");
//使用 QueryParameter 陣列作為條件，適合於多個並列的And條件
//q.Select().Where(new QueryParameter[] { new QueryParameter("Age", PWMIS.Common.enumCompare.NoSmaller, 15) }).OrderBy(u.Age, "asc");
Console.WriteLine("--OQL to SQL:rn"+q.ToString ());
//*************構建 OQL 查詢表示式 ******* end ************
//查詢實體列表
var result = EntityQuery<User>.QueryList(q);
Console.WriteLine("--查詢實體集合成功，數量："+result .Count );
Console.WriteLine("rn--Executed SQL Text:rn{0}rn", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);
//查詢單個實體
u.Name = "zhang san";
q.Select().Where(u.Name);
Console.WriteLine("--OQL to SQL:rn" + q.ToString());
User u1 = EntityQuery<User>.QueryObject(q);
if (u1 != null)
Console.WriteLine("--查詢單個實體成功！");
Console.WriteLine("rn--Executed SQL Text:rn{0}rn", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);
//直接使用EntityQuery<T>.Instance 屬性的插入、修改、刪除方法
u.Name = "li si5";
u.Age = 28;
//PostgreSQL 沒有 @@IDENTITY 變數，所以無法拿到剛才的自增值
//但可以使用 select currval('User_ID_seq');
//所以必須設定當前實體對應的表的自增欄位序列名稱
//db.InsertKey = "User_ID_seq";
// Ver 5.6.0.1121 之後，框架取消了這一個限制
if (EntityQuery<User>.Instance.Insert(u,db) > 0)
Console.WriteLine("--插入實體成功！"); //將自動為ID屬性賦值
Console.WriteLine("rn--Executed SQL Text:rn{0}rn", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);
u.Age = 29;
if (EntityQuery<User>.Instance.Update(u,db) > 0)
Console.WriteLine("修改實體成功！");
Console.WriteLine("rnExecuted SQL Text:rn{0}rn", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);
User u2 = new User();
u2.Name = "wang wu";
u2.Age = 20;
//使用EntityQuery<T> 的例項物件方法更新實體
//只會更新賦值過的屬性值
EntityQuery<User> eq = new EntityQuery<User>(u2);
eq.DefaultDataBase = db;//必須設定當前資料庫訪問物件
if (eq.SaveAllChanges() > 0)
Console.WriteLine("--更新實體成功！");
Console.WriteLine("rn--Executed SQL Text:rn{0}rn", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);
Console.Read();
}
}
}注意上面程式碼中的這一部分：
//PostgreSQL 沒有 @@IDENTITY 變數，所以無法拿到剛才的自增值 //但可以使用 select currval('User_ID_seq'); //所以必須設定當前實體對應的表的自增欄位序列名稱 db.InsertKey = "User_ID_seq";
在PostgreSQL中，不同的表需要設定不同的 InsertKey ，而在SQLSERVER等資料庫中，始終採用 InsertKey=“select @@IDENTITY ”;
注：在PDF.NET SOD框架 5.6.0.1121 之後，框架取消了這一個限制。不過原理上跟以前是一樣的，只不過框架自動處理了這個問題，前提是你必須使用SOD自帶的處理自增的方式，自動建立表。
5，編譯執行，得到下面的結果：
--OQL to SQL:
SELECT [ID],[Name],[Age]
FROM [tb_user]
Where [Age] >= @Age0
Order by [Age] asc
--查詢實體集合成功，數量：18
--Executed SQL Text:
SELECT "ID","Name","Age"
FROM "tb_user"
Where "Age" >= @Age0
Order by "Age" asc
--OQL to SQL:
SELECT [ID],[Name],[Age]
FROM [tb_user]
Where [Name]=@Name
--查詢單個實體成功！
--Executed SQL Text:
SELECT "ID","Name","Age"
FROM "tb_user"
Where "Name"=@Name
--插入實體成功！
--Executed SQL Text:
INSERT INTO "tb_user"("Name","Age") VALUES (@P0,@P1)
修改實體成功！
Executed SQL Text:
UPDATE "tb_user" SET "Age"=@P0 WHERE "ID"=@P1
--更新實體成功！
--Executed SQL Text:
INSERT INTO "tb_user"("Name","Age") VALUES (@P0,@P1)注意：在PostgreSQL中，SQL語句中的欄位名要使用雙引號，PDF.NET資料開發框架為你自動完成這一切，使得你的SQL語句能夠很容易的移植到PostgreSQL。
最後，附帶一個PostgreSQL中使用觸發器模擬自增與不使用自增，還有跟MySQL自增下，CRUD資料的一個效率對比測試資料，測試程式請看原始碼的 SampleOrmTest示例：
====**************** PDF.NET SOD ORM 控制檯測試程式 **************====
框架核心程式集 PWMIS.Core Version:5.6.0.1111
====應用程式配置檔案預設的資料庫配置資訊：===========================
-------測試1---使用觸發器做自增測試------------------------------
當前使用的資料庫型別是：PostgreSQL
連線字串為:server=127.0.0.1;User Id=root;password=;DataBase=mydb
請確保資料庫伺服器和資料庫是否有效（SqlServer,Access 會自動建立資料庫），
繼續請回車，退出請輸入字母 Q .
=====Power by Bluedoctor,2015.3.1 http://www.pwmis.com/sqlmap =======
-------PDF.NET SOD ORM 測試 開始 ---------
測試：使用者zhang san 的密碼和註冊日期已經更新
--刪除 1002條資料--
--插入 1001條資料--
--修改 3次資料，User ID：1048--
SOD ORM的 6種 查詢方式，開始----
Login0:True
Login1:True
Login2:True
Login3:True
Login4:True
Login5:True
Login6:False
模糊查詢姓 張 的使用者，數量:10
-------PDF.NET SOD ORM 測試 全部結束-----
耗時：(ms)1050
-------測試2---不使用觸發器做自增測試------------------------------
當前使用的資料庫型別是：PostgreSQL
連線字串為:server=127.0.0.1;User Id=root;password=;DataBase=mydb
請確保資料庫伺服器和資料庫是否有效（SqlServer,Access 會自動建立資料庫），
繼續請回車，退出請輸入字母 Q .
=====Power by Bluedoctor,2015.3.1 http://www.pwmis.com/sqlmap =======
-------PDF.NET SOD ORM 測試 開始 ---------
測試：使用者zhang san 的密碼和註冊日期已經更新
--刪除 1001條資料--
--插入 1001條資料--
--修改 0次資料，User ID：0--
SOD ORM的 6種 查詢方式，開始----
Login0:True
Login1:True
Login2:True
Login3:True
Login4:True
Login5:True
Login6:False
模糊查詢姓 張 的使用者，數量:10
-------PDF.NET SOD ORM 測試 全部結束-----
耗時：(ms)779
======================================================
-------測試3---MySQL對比測試（使用自增）------------------------------
當前使用的資料庫型別是：MySql
連線字串為:server=127.0.0.1;User Id=root;password=;DataBase=test
請確保資料庫伺服器和資料庫是否有效（SqlServer,Access 會自動建立資料庫），
繼續請回車，退出請輸入字母 Q .
=====Power by Bluedoctor,2015.3.1 http://www.pwmis.com/sqlmap =======
-------PDF.NET SOD ORM 測試 開始 ---------
測試：使用者zhang san 的密碼和註冊日期已經更新
--刪除 1002條資料--
--插入 1001條資料--
--修改 3次資料，User ID：11103--
SOD ORM的 6種 查詢方式，開始----
Login0:True
Login1:True
Login2:True
Login3:True
Login4:True
Login5:True
Login6:False
模糊查詢姓 張 的使用者，數量:10
-------PDF.NET SOD ORM 測試 全部結束-----
耗時：(ms)604