-
-
Save jsumners/8849909 to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/* | |
* The author disclaims copyright to this source code. In place of | |
* a legal notice, here is a blessing: | |
* | |
* May you do good and not evil. | |
* May you find forgiveness for yourself and forgive others. | |
* May you share freely, never taking more than you give. | |
* | |
*/ | |
package org.hibernate.dialect; | |
import java.sql.Types; | |
import org.hibernate.dialect.function.SQLFunctionTemplate; | |
import org.hibernate.dialect.function.StandardSQLFunction; | |
import org.hibernate.dialect.function.VarArgsSQLFunction; | |
import org.hibernate.dialect.pagination.LimitHandler; | |
import org.hibernate.dialect.pagination.SQLiteLimitHandler; | |
import org.hibernate.engine.spi.RowSelection; | |
import org.hibernate.type.IntegerType; | |
import org.hibernate.type.StringType; | |
/** | |
* <a href="https://gist.github.com/virasak/54436">https://gist.github.com/virasak/54436</a> | |
*/ | |
public class SQLiteDialect extends Dialect { | |
public SQLiteDialect() { | |
registerColumnType(Types.BIT, "integer"); | |
registerColumnType(Types.TINYINT, "tinyint"); | |
registerColumnType(Types.SMALLINT, "smallint"); | |
registerColumnType(Types.INTEGER, "integer"); | |
registerColumnType(Types.BIGINT, "bigint"); | |
registerColumnType(Types.FLOAT, "float"); | |
registerColumnType(Types.REAL, "real"); | |
registerColumnType(Types.DOUBLE, "double"); | |
registerColumnType(Types.NUMERIC, "numeric"); | |
registerColumnType(Types.DECIMAL, "decimal"); | |
registerColumnType(Types.CHAR, "char"); | |
registerColumnType(Types.VARCHAR, "varchar"); | |
registerColumnType(Types.LONGVARCHAR, "longvarchar"); | |
registerColumnType(Types.DATE, "date"); | |
registerColumnType(Types.TIME, "time"); | |
registerColumnType(Types.TIMESTAMP, "timestamp"); | |
registerColumnType(Types.BINARY, "blob"); | |
registerColumnType(Types.VARBINARY, "blob"); | |
registerColumnType(Types.LONGVARBINARY, "blob"); | |
// registerColumnType(Types.NULL, "null"); | |
registerColumnType(Types.BLOB, "blob"); | |
registerColumnType(Types.CLOB, "clob"); | |
registerColumnType(Types.BOOLEAN, "integer"); | |
registerFunction( "concat", new VarArgsSQLFunction(StringType.INSTANCE, "", "||", "") ); | |
registerFunction( "mod", new SQLFunctionTemplate(IntegerType.INSTANCE, "?1 % ?2" ) ); | |
registerFunction( "substr", new StandardSQLFunction("substr", StringType.INSTANCE) ); | |
registerFunction( "substring", new StandardSQLFunction( "substr", StringType.INSTANCE) ); | |
} | |
@Override | |
public boolean supportsIdentityColumns() { | |
return true; | |
} | |
/* | |
public boolean supportsInsertSelectIdentity() { | |
return true; // As specify in NHibernate dialect | |
} | |
*/ | |
@Override | |
public boolean hasDataTypeInIdentityColumn() { | |
return false; // As specify in NHibernate dialect | |
} | |
/* | |
public String appendIdentitySelectToInsert(String insertString) { | |
return new StringBuffer(insertString.length()+30). // As specify in NHibernate dialect | |
append(insertString). | |
append("; ").append(getIdentitySelectString()). | |
toString(); | |
} | |
*/ | |
@Override | |
public String getIdentityColumnString() { | |
// return "integer primary key autoincrement"; | |
return "integer"; | |
} | |
@Override | |
public String getIdentitySelectString() { | |
return "select last_insert_rowid()"; | |
} | |
@Override | |
public LimitHandler buildLimitHandler(String sql, RowSelection selection) { | |
return new SQLiteLimitHandler(sql, selection); | |
} | |
@Override | |
public boolean supportsTemporaryTables() { | |
return true; | |
} | |
@Override | |
public String getCreateTemporaryTableString() { | |
return "create temporary table if not exists"; | |
} | |
@Override | |
public boolean dropTemporaryTableAfterUse() { | |
return false; | |
} | |
@Override | |
public boolean supportsCurrentTimestampSelection() { | |
return true; | |
} | |
@Override | |
public boolean isCurrentTimestampSelectStringCallable() { | |
return false; | |
} | |
@Override | |
public String getCurrentTimestampSelectString() { | |
return "select current_timestamp"; | |
} | |
@Override | |
public boolean supportsUnionAll() { | |
return true; | |
} | |
@Override | |
public boolean hasAlterTable() { | |
return false; // As specify in NHibernate dialect | |
} | |
@Override | |
public boolean dropConstraints() { | |
return false; | |
} | |
@Override | |
public String getAddColumnString() { | |
return "add column"; | |
} | |
@Override | |
public String getForUpdateString() { | |
return ""; | |
} | |
@Override | |
public boolean supportsOuterJoinForUpdate() { | |
return false; | |
} | |
@Override | |
public String getDropForeignKeyString() { | |
throw new UnsupportedOperationException("No drop foreign key syntax supported by SQLiteDialect"); | |
} | |
@Override | |
public String getAddForeignKeyConstraintString(String constraintName, | |
String[] foreignKey, String referencedTable, String[] primaryKey, | |
boolean referencesPrimaryKey) { | |
throw new UnsupportedOperationException("No add foreign key syntax supported by SQLiteDialect"); | |
} | |
@Override | |
public String getAddPrimaryKeyConstraintString(String constraintName) { | |
throw new UnsupportedOperationException("No add primary key syntax supported by SQLiteDialect"); | |
} | |
@Override | |
public boolean supportsIfExistsBeforeTableName() { | |
return true; | |
} | |
@Override | |
public boolean supportsCascadeDelete() { | |
return false; | |
} | |
} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package org.hibernate.dialect.pagination; | |
import org.hibernate.engine.spi.RowSelection; | |
/** | |
* An implementation of {@link org.hibernate.dialect.pagination.LimitHandler} | |
* for the {@link org.hibernate.dialect.SQLiteDialect} based on | |
* {@link org.hibernate.dialect.pagination.CUBRIDLimitHandler}. | |
*/ | |
public class SQLiteLimitHandler extends AbstractLimitHandler { | |
/** | |
* {@inheritDoc} | |
*/ | |
public SQLiteLimitHandler(String sql, RowSelection selection) { | |
super(sql, selection); | |
} | |
@Override | |
public boolean supportsLimit() { | |
return true; | |
} | |
@Override | |
public String getProcessedSql() { | |
String result; | |
if (LimitHelper.useLimit(this, this.selection)) { | |
final boolean useLimitOffset = LimitHelper.hasFirstRow(this.selection); | |
result = this.sql + (useLimitOffset ? " limit ? offset ?" : " limit ?"); | |
} else { | |
result = this.sql; | |
} | |
return result; | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
For what Hibernate version is this snippet? Seems not suitable for 5.0.4 or am I doing something wrong? Thanks!