Hibernate一直没有提供针对SqlServer2005的Dialect,原有的SqlServerDialect不支持物理分页查询。最近经常使用SqlServer2005,所以就很想写一个使用SqlServer2005 ROW_NUMBER()函数实现limit查询的Dialect类。
下面这个类是使用ROW_NUMBER()函数分页的Dialect,开始是从NHibernate移植的,后来又参考了Hibernate的Jira(
http://opensource.atlassian.com/projects/hibernate/browse/HHH-2655)。不知道为什,Jira上的那个有BUG类可以很简单的修改,但是却没人理会。所以我感觉下面这个类可能也存在问题,有兴趣的朋友帮忙测测。
public class SQLServer2005Dialect extends SQLServerDialect {
public SQLServer2005Dialect() {
super();
registerColumnType(Types.VARCHAR, 1073741823, "NVARCHAR(MAX)");
registerColumnType(Types.VARCHAR, 2147483647, "VARCHAR(MAX)");
registerColumnType(Types.VARBINARY, 2147483647, "VARBINARY(MAX)");
}
/**
* Add a LIMIT clause to the given SQL SELECT
*
* The LIMIT SQL will look like:
*
* WITH query AS
* (SELECT TOP 100 percent ROW_NUMBER() OVER (ORDER BY orderby) as __hibernate_row_nr__, ... original_query)
* SELECT *
* FROM query
* WHERE __hibernate_row_nr__ > offset AND __hibernate_row_nr__ <= offset + limit
* ORDER BY __hibernate_row_nr__
*
* @param querySqlString The SQL statement to base the limit query off of.
* @param offset Offset of the first row to be returned by the query (zero-based)
* @param limit Maximum number of rows to be returned by the query
* @return A new SQL statement with the LIMIT clause applied.
*/
public String getLimitString(String querySqlString, int offset, int limit) {
StringBuffer pagingBuilder = new StringBuffer();
String orderby = getOrderByPart(querySqlString);
String distinctStr = "";
String loweredString = querySqlString.toLowerCase();
String sqlPartString = querySqlString.trim();
if (loweredString.trim().startsWith("select")) {
int index = 6;
if (loweredString.startsWith("select distinct")) {
distinctStr = "DISTINCT ";
index = 15;
}
sqlPartString = sqlPartString.substring(index);
}
pagingBuilder.append(sqlPartString);
// if no ORDER BY is specified use fake ORDER BY field to avoid errors
if (orderby == null || orderby.length() == 0) {
orderby = "ORDER BY CURRENT_TIMESTAMP";
}
StringBuffer result = new StringBuffer();
result.append("WITH query AS (SELECT ")
.append(distinctStr)
.append(" TOP 100 PERCENT ROW_NUMBER() OVER (") //使用TOP 100 PERCENT可以提高性能
.append(orderby)
.append(") AS __hibernate_row_nr__, ")
.append(pagingBuilder)
.append(") SELECT * FROM query WHERE __hibernate_row_nr__ >")
.append(offset)
.append(" AND __hibernate_row_nr__ <=")
.append(offset + limit)
.append(" ORDER BY __hibernate_row_nr__");
return result.toString();
}
public boolean supportsLimit() {
return true;
}
static String getOrderByPart(String sql) {
String loweredString = sql.toLowerCase();
int orderByIndex = loweredString.indexOf("order by");
if (orderByIndex != -1) {
// if we find a new "order by" then we need to ignore
// the previous one since it was probably used for a subquery
return sql.substring(orderByIndex);
} else {
return "";
}
}
}
分享到:
相关推荐
SQLServer2008Dialect 优化了原来的分页查询数据方法以及在生成SQL时表后增加了with(nolock)
DatabaseName=test"),用户名("sa"),密码("518168"),驱动类("com.microsoft.sqlserver.jdbc.SQLServerDriver"),以及方言("org.hibernate.dialect.SQLServerDialect")。方言用于使Hibernate能够生成适应...
<property name="hibernate.connection.url">jdbc:sqlserver://localhost:1433;databaseName=testDB <property name="hibernate.connection.username">username <property name="hibernate.connection.password">...
对于SQL Server 2000,应使用`HibernateDialect`的子类,如`net.sf.hibernate.dialect.SQLServer2000Dialect`。 4. **JDBC版本**:由于SQL Server 2000使用的是JDBC 3.0,而较新的Java版本可能默认使用JDBC 4.x,...
<property name="hibernate.connection.url">jdbc:sqlserver://localhost:1433;databaseName=testdb <property name="hibernate.connection.username">username <property name="hibernate.connection.password">...
<prop key="hibernate.dialect">org.hibernate.dialect.SQLServer2012Dialect <prop key="hibernate.show_sql">true <value>com/yourpackage/YourEntity.hbm.xml</value> ``` 接下来,我们需要创建...
SQLServer 数据库 SSH 配置详解 SQLServer 数据库 SSH 配置是将 SQLServer 数据库与 Secure Shell(SSH)协议集成,以实现加密的数据传输和身份验证。本文将详细介绍 SQLServer 数据库 SSH 配置的实现步骤和相关...
[http60-Processor1][org.hibernate.util.JDBCExceptionReporter][ERROR] - [Microsoft][SQLServer2000DriverforJDBC] Broken pipe ``` 这些异常通常意味着数据库连接被意外关闭或者重置了。 #### 三、配置详解 ...
例如`jdbc:sqlserver://localhost:1433;DatabaseName=hibernate_first`。 - **`hibernate.connection.username`**:指定连接数据库的用户名。 - **`hibernate.connection.password`**:指定连接数据库的密码。 - **`...
第一步:hibernate.cfg.xml 加入: <property name="hibernate.proxool.pool_alias">dbpool</property> ...jdbc:microsoft:sqlserver://243.155.187.236:1433;DatabaseName=study </driver-url> <driver-
首先,Hibernate提供了一些基本的数据库连接驱动程序,例如mysql、oracle、sqlserver等。这些驱动程序可以让Hibernate连接不同的数据库。但是,为了确保数据的正确性和一致性,Hibernate还需要使用不同的SQL方言来...
<property name="hibernate.dialect">org.hibernate.dialect.SQLServer2012Dialect <property name="hibernate.connection.driver_class">com.microsoft.sqlserver.jdbc.SQLServerDriver</property> ...
hibernate.connection.url jdbc:jnetdirect:sqlserver://your_server:port;databaseName=your_database ``` 请根据实际的数据库连接信息替换`your_username`、`your_password`、`your_server`、`port`和`your_...
- **SQL Server2005 Dialect**:针对SQL Server 2005版本的优化。 - **SQL Server2008 Dialect**:包含对SQL Server 2008特性的支持。 #### SAP DB - **SAPDB Dialect**:为SAP DB数据库提供方言支持。 #### ...
在将SSH项目从SQL Server 2005迁移至MySQL时,出现的“org.springframework.dao.InvalidDataAccessResourceUsageException: could not execute query”异常通常意味着数据访问层在尝试执行SQL查询时遇到了问题。...
在这个“NHibernate+sqlserver练习”项目中,我们将会探讨如何结合NHibernate和MVVM(Model-View-ViewModel)设计模式来实现基本的数据操作功能,包括增、删、改、查。 首先,我们要理解NHibernate的核心概念。它是...
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); Connection conn = DriverManager.getConnection( "jdbc:sqlserver://localhost:1433;databaseName=myDatabase", "username", "password"); ...
hibernate.dialect=org.hibernate.dialect.SQLServerDialect jdbc.default.driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver jdbc.default.url=jdbc:sqlserver://127.0.0.1:1433;databaseName=...
在示例错误信息中提到的“Caused by: java.sql.SQLException: [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]'last_insert_id' 不是可以识别的函数名”,这是由于`last_insert_id`函数在SQL Server中并不...