ORM框架EntitysCodeGenerate自定义分页查询及快捷执行SQL(CreateSQL)示例

1、自定义分页查询(Skip/Take)

如下代码所示：

DbCore dbCore;

 

//Oracle 分页

dbCore = new DbCore(DatabaseType.Oracle, myOracle.BaseEntity.GetConnectionString());

DataSet dstOracle = dbCore.Select().Add(myOracle.DEPTColumn.DEPTNO)

                    .Add(myOracle.DEPTColumn.DNAME).Add(myOracle.DEPTColumn.LOC)

                    .Add(myOracle.EMPColumn.EMPNO).SelectColumn(myOracle.EMPColumn.ENAME)

                .From(myOracle.DEPTColumn.TableName).FromTable(myOracle.EMPColumn.TableName)

                .Where().ConditionColumnAndEqual(myOracle.DEPTColumn.DEPTNO, myOracle.EMPColumn.DEPTNO)

                .ConditionAndEqual(myOracle.DEPTColumn.DEPTNO,20)

                .OrderBy().Asc(myOracle.EMPColumn.DEPTNO).Skip(2).Take(3).ExecuteDataSet();

int countOracle = dstOracle.Tables[0].Rows.Count;

 

//未设置Oracle排序字段,默认数字1,但可能不是想要的顺序
dstOracle = dbCore.Select().Add(myOracle.DEPT.s_DEPTNO)

                    .Add(myOracle.DEPT.s_DNAME).Add(myOracle.DEPT.s_LOC)

                    .Add(myOracle.EMP.s_EMPNO).SelectColumn(myOracle.EMP.s_ENAME)

                .From(myOracle.DEPT.s_TableName).FromTable(myOracle.EMP.s_TableName)

                .Where().ConditionColumnAndEqual(myOracle.DEPT.s_DEPTNO, myOracle.EMP.s_DEPTNO)

                .ConditionAndGreatEqual(myOracle.DEPT.s_DEPTNO, 20)

                .OrderBy().Skip(2).Take(3).ExecuteDataSet();

countOracle = dstOracle.Tables[0].Rows.Count;

 

//SqlServer 分页,必须设置排序字段

dbCore = new DbCore(DatabaseType.SqlServer, mySqlServer2008.BaseEntity.GetConnectionString());

DataSet dstSqlServer = dbCore.Select().Add(mySqlServer2008.DEPT.s_DEPTNO)

                    .Add(mySqlServer2008.DEPT.s_DNAME).Add(mySqlServer2008.DEPT.s_LOC)

                    .Add(mySqlServer2008.EMP.s_EMPNO).SelectColumn(mySqlServer2008.EMP.s_ENAME)

                .From(mySqlServer2008.DEPT.s_TableName).FromTable(mySqlServer2008.EMP.s_TableName)

                .Where().ConditionColumnAndEqual(mySqlServer2008.DEPT.s_DEPTNO, mySqlServer2008.EMP.s_DEPTNO)

                .ConditionAndGreatEqual(myOracle.DEPT.s_DEPTNO, 20)

                .OrderBy().Asc(mySqlServer2008.DEPT.s_DEPTNO).Skip(1).Take(2).ExecuteDataSet();

int countSqlServer = dstSqlServer.Tables[0].Rows.Count;

 

//Sqlite 分页

dbCore = new DbCore(DatabaseType.SQLite, mySqlite.BaseEntity.GetConnectionString());

DataSet dstSqlite = dbCore.Select().Add(Entity.Common.SQLite.t_demo.s_z)

                    .Add(Entity.Common.SQLite.t_demo.s_a).Add("b")

                .From(Entity.Common.SQLite.t_demo.s_TableName)

                .OrderBy().Asc("z").Skip(1).Take(2).ExecuteDataSet();

int countSqlite = dstSqlite.Tables[0].Rows.Count;

 

//MySql 分页

dbCore = new DbCore(DatabaseType.MySql, myMySql.BaseEntity.GetConnectionString());

DataSet dstMySql = dbCore.Select().Add(myMySql.dept.s_DEPTNO).Add("DNAME").Add("LOC")

                .From(myMySql.dept.s_TableName)

                .OrderBy().Desc(myMySql.dept.s_DEPTNO).Skip(1).Take(2).ExecuteDataSet();

int countMySql = dstMySql.Tables[0].Rows.Count;

 

//DB2 分页

dbCore = new DbCore(DatabaseType.DB2, myDB2.BaseEntity.GetConnectionString());

DataSet dstDB2 = dbCore.Select().Add(myDB2.TESTENTITY.s_A).Add(myDB2.TESTENTITY.s_B)

                .Add(myDB2.TESTENTITY.s_C).Add(myDB2.TESTENTITY.s_D)

                .From(myDB2.TESTENTITY.s_TableName)

                .OrderBy().Asc(myDB2.TESTENTITY.s_A).Skip(1).Take(2).ExecuteDataSet();

int countDB2 = dstDB2.Tables[0].Rows.Count;

 

//PostgreSQL分页

dbCore = new DbCore(DatabaseType.PostgreSQL, myPostgreSQL.BaseEntity.GetConnectionString());

DataSet dstPostgreSQL = dbCore.Select().Add(myPostgreSQL.t_tabledemoColumn.c_a)

                .Add(myPostgreSQL.t_tabledemoColumn.c_b).Add(myPostgreSQL.t_tabledemoColumn.c_c)

                .From(myPostgreSQL.t_tabledemoColumn.TableName)//.FromCustom("tt")

                .OrderBy().Asc(myPostgreSQL.t_tabledemoColumn.c_a).Skip(1).Take(2).ExecuteDataSet();

int countPostgreSQL = dstPostgreSQL.Tables[0].Rows.Count;

 

 

//DM(达梦)分页

dbCore = new DbCore(DatabaseType.Dm, myDM.BaseEntity.GetConnectionString());

DataSet dstDM = dbCore.Select().Add(myDM.T_DEMO.s_C_A).Add(myDM.T_DEMO.s_C_B)

                .Add(myDM.T_DEMO.s_C_C).Add(myDM.T_DEMO1.s_C_NAME)

                .From(myDM.T_DEMO.s_TableName).FromTable(myDM.T_DEMO1.s_TableName)

                .Where().ConditionColumnAndEqual(myDM.T_DEMO.s_C_ID, myDM.T_DEMO1.s_C_ID)

                .OrderBy().Asc(myDM.T_DEMO.s_C_A).Skip(1).Take(2).ExecuteDataSet();

int countDM = dstDM.Tables[0].Rows.Count;

Skip为跳过元素的数量，Take为所取连续元素的数量。

目前这种分页方式支持的数据库：Oracle/SqlServer/MySql/Sqlite/PostgreSQL/
DM/DB2/Sybase IQ/Informix/Firebird/

 

通用分页也可以使用System.Database.Extend.TableHelp类。

 

2.、DbCore+SQL快捷用法

DbCore dbCore = new DbCore(myOracle.BaseEntity.GetConnectionString());

DataSet dst = dbCore.CreateSQL("select * from emp where deptno = :deptno")

    .AddInParameter("deptno", DbType.Int32, 20).ExecuteDataSet();

int intCount = dst.Tables[0].Rows.Count;

 

 

 

下载链接：

http://www.cnblogs.com/lxchutao/archive/2011/06/01/2065977.html