From 84885d79aa265b9dd20b43b5f553b27ead55eb6e Mon Sep 17 00:00:00 2001 From: Alex Telepov Date: Mon, 31 Dec 2012 09:42:20 -0500 Subject: [PATCH] Preliminary MSSQL dialect --- src/com/iciql/Db.java | 2 ++ src/com/iciql/SQLDialectMSSQL.java | 53 ++++++++++++++++++++++++++++++ 2 files changed, 55 insertions(+) create mode 100644 src/com/iciql/SQLDialectMSSQL.java diff --git a/src/com/iciql/Db.java b/src/com/iciql/Db.java index 32b7c6a..d7888dc 100644 --- a/src/com/iciql/Db.java +++ b/src/com/iciql/Db.java @@ -2,6 +2,7 @@ * Copyright 2004-2011 H2 Group. * Copyright 2011 James Moger. * Copyright 2012 Frederic Gaillard. + * Copyright 2012 Alex Telepov. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -83,6 +84,7 @@ public class Db { DIALECTS.put("HSQL Database Engine", SQLDialectHSQL.class); DIALECTS.put("MySQL", SQLDialectMySQL.class); DIALECTS.put("PostgreSQL", SQLDialectPostgreSQL.class); + DIALECTS.put("Microsoft SQL Server", SQLDialectMSSQL.class); } private Db(Connection conn) { diff --git a/src/com/iciql/SQLDialectMSSQL.java b/src/com/iciql/SQLDialectMSSQL.java new file mode 100644 index 0000000..92b1297 --- /dev/null +++ b/src/com/iciql/SQLDialectMSSQL.java @@ -0,0 +1,53 @@ +/* + * Copyright 2012 Alex Telepov. + * Copyright 2012 James Moger. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.iciql; + +/** + * MS SQL Server database dialect. + */ +public class SQLDialectMSSQL extends SQLDialectDefault { + + /** + * Append limit and offset rows + * + * @param stat Statement + * @param limit Limit rows + * @param offset Offset rows + */ + @Override + public void appendLimitOffset(SQLStatement stat, long limit, long offset) { + if (offset > 0) { + throw new IciqlException("iciql does not support offset for MSSQL dialect!"); + } + StringBuilder query = new StringBuilder(stat.getSQL()); + + // for databaseVersion >= 2012 need Offset + if (limit > 0) { + int indexSelect = query.indexOf("SELECT"); + + if (indexSelect >= 0) { + StringBuilder subPathQuery = new StringBuilder(" TOP "); + subPathQuery.append(Long.toString(limit)); + + query.insert(indexSelect + "SELECT".length(), subPathQuery); + + stat.setSQL(query.toString()); + } + } + } +} -- 2.39.5