PDF.NET数据开发框架实体类操作实例之在PostgreSQL中操作

本篇是PDF.NET数据开发框架实体类操作实例之在MySQL中操作的姊妹篇，两者使用了同一个测试程序，不同的只是使用的类库和数据库不同，下面说说具体的使用过程。

成都创新互联公司服务项目包括云龙网站建设、云龙网站制作、云龙网页制作以及云龙网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，云龙网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到云龙省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！

1，首先在App.config文件中配置数据库连接字符串：

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("ID"); }  
  
  
              set { setProperty("ID", value); }  
  
  
          }  
  
  
   
  
  
          public int Age  
  
  
          {  
  
  
              get { return getProperty("Age"); }  
  
  
              set { setProperty("Age", value); }  
  
  
          }  
  
  
   
  
  
          public string Name  
  
  
          {  
  
  
              get { return getProperty("Name"); }  
  
  
              set { setProperty("Name", value,50); }  
  
  
          }  
  
  
      }  
  
  
  }

与MySQL中定义的用户实体类不同，下面这一行代码被注释掉了：

//IdentityName = "ID";//标识，自增
虽然PostgreSQL有“自增”列，但无法直接取到刚插入的这个自增值，所以需要注释它。

3，根据这个实体类，我们去MySQL定义一个用户表：tb_user，具体过程省略，注意字段“ID”仍然使用自增列（在PostgreSQL中是 serial 类型，但编辑表类型的时候，发现字段是整数类型，不过有了默认值：nextval('"User_ID_seq"'::regclass)）。

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",22) });  
  
  
   
  
  
                
  
  
              //  
  
  
              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:\r\n"+q.ToString ());  
  
  
   
  
  
                
  
  
              //*************构建 OQL 查询表达式 ******* end ************  
  
  
   
  
  
              //查询实体列表  
  
  
              var result = EntityQuery.QueryList(q);  
  
  
              Console.WriteLine("查询实体集合成功，数量："+result .Count );  
  
  
   
  
  
              Console.WriteLine("\r\nExecuted SQL Text:\r\n{0}\r\n", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);  
  
  
   
  
  
              //查询单个实体  
  
  
              u.Name = "zhang san";  
  
  
              q.Select().Where(u.Name);  
  
  
              Console.WriteLine("OQL to SQL:\r\n" + q.ToString());  
  
  
              User u1 = EntityQuery.QueryObject(q);  
  
  
              if (u1 != null)  
  
  
                  Console.WriteLine("查询单个实体成功！");  
  
  
   
  
  
              Console.WriteLine("\r\nExecuted SQL Text:\r\n{0}\r\n", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);  
  
  
   
  
  
   
  
  
              //直接使用EntityQuery.Instance 属性的插入、修改、删除方法  
  
  
              u.Name = "li si3";  
  
  
              u.Age = 15;  
  
  
              if (EntityQuery.Instance.Insert(u) > 0)  
  
  
                  Console.WriteLine("插入实体成功！"); //将自动为ID属性赋值  
  
  
   
  
  
              Console.WriteLine("\r\nExecuted SQL Text:\r\n{0}\r\n", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);  
  
  
   
  
  
              //PostgreSQL 没有 @@IDENTITY 变量，所以无法拿到刚才的自增值，注释掉下面的修改方法  
  
  
              //u.Age = 25;  
  
  
              //if (EntityQuery.Instance.Update (u) > 0)  
  
  
              //    Console.WriteLine("修改实体成功！");  
  
  
   
  
  
              //Console.WriteLine("\r\nExecuted SQL Text:\r\n{0}\r\n", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);  
  
  
   
  
  
              User u2 = new User();  
  
  
              u2.Name = "wang wu";  
  
  
              u2.Age = 20;  
  
  
   
  
  
              //使用EntityQuery 的实例对象方法更新实体  
  
  
              //只会更新赋值过的属性值  
  
  
              EntityQuery eq = new EntityQuery(u2);  
  
  
              if (eq.SaveAllChanges() > 0)  
  
  
                  Console.WriteLine("更新实体成功！");  
  
  
   
  
  
              Console.WriteLine("\r\nExecuted SQL Text:\r\n{0}\r\n", PWMIS.DataProvider.Data.CommandLog.Instance.CommandText);  
  
  
   
  
  
              Console.Read();  
  
  
          }  
  
  
      }  
  
  
  }

注意上面代码中的这一部分：

//PostgreSQL 没有 @@IDENTITY 变量，所以无法拿到刚才的自增值，注释掉下面的修改方法
虽然注释了修改实体的方法，但只要手工给ID属性设置值，仍然可以修改实体。

5，编译运行，得到下面的结果：

 
 
 
  
  
  --OQL to SQL:  
  
  
  SELECT [ID],[Name],[Age]  
  
  
  FROM [tb_user]  
  
  
     Where  [Age] >= @Age0  
  
  
          Order by [Age] asc  
  
  
  --查询实体集合成功，数量：8  
  
  
   
  
  
  --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:  
  
  
  INSERT INTO "tb_user"("Name","Age") VALUES (@P0,@P1)

注意：在PostgreSQL中，SQL语句中的字段名要使用双引号。

原文链接：http://www.cnblogs.com/bluedoctor/archive/2011/04/26/2029005.html

【编辑推荐】

用C++连接MySQL等数据库一
用C++连接MySQL等数据库二
这些SQLite与SQL差异问题，你遇到过吗
如何将AS3连接到MySQL数据库上
PDF.NET数据开发框架实体类操作实例之在MySQL中操作

标题名称：PDF.NET数据开发框架实体类操作实例之在PostgreSQL中操作
标题来源：http://www.csdahua.cn/qtweb/news10/259160.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：快上网

成都快上网为您推荐相关内容