Open Source Repository

Home /hibernate/hibernate-3.2.7.ga | Repository Home



org/hibernate/dialect/AbstractTransactSQLDialect.java
//$Id: $
package org.hibernate.dialect;

import java.sql.CallableStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Types;
import java.util.Map;
import java.util.Iterator;

import org.hibernate.Hibernate;
import org.hibernate.LockMode;
import org.hibernate.cfg.Environment;
import org.hibernate.dialect.function.CharIndexFunction;
import org.hibernate.dialect.function.NoArgSQLFunction;
import org.hibernate.dialect.function.SQLFunctionTemplate;
import org.hibernate.dialect.function.StandardSQLFunction;
import org.hibernate.dialect.function.VarArgsSQLFunction;

/**
 * An abstract base class for Sybase and MS SQL Server dialects.
 @author Gavin King
 */

/* package-private */
abstract class AbstractTransactSQLDialect extends Dialect {
  public AbstractTransactSQLDialect() {
    super();
    registerColumnTypeTypes.BIT, "tinyint" )//Sybase BIT type does not support null values
    registerColumnTypeTypes.BIGINT, "numeric(19,0)" );
    registerColumnTypeTypes.SMALLINT, "smallint" );
    registerColumnTypeTypes.TINYINT, "tinyint" );
    registerColumnTypeTypes.INTEGER, "int" );
    registerColumnTypeTypes.CHAR, "char(1)" );
    registerColumnTypeTypes.VARCHAR, "varchar($l)" );
    registerColumnTypeTypes.FLOAT, "float" );
    registerColumnTypeTypes.DOUBLE, "double precision" );
    registerColumnTypeTypes.DATE, "datetime" );
    registerColumnTypeTypes.TIME, "datetime" );
    registerColumnTypeTypes.TIMESTAMP, "datetime" );
    registerColumnTypeTypes.VARBINARY, "varbinary($l)" );
    registerColumnTypeTypes.NUMERIC, "numeric($p,$s)" );
    registerColumnTypeTypes.BLOB, "image" );
    registerColumnTypeTypes.CLOB, "text" );

    registerFunction"ascii"new StandardSQLFunction("ascii", Hibernate.INTEGER) );
    registerFunction"char"new StandardSQLFunction("char", Hibernate.CHARACTER) );
    registerFunction"len"new StandardSQLFunction("len", Hibernate.LONG) );
    registerFunction"lower"new StandardSQLFunction("lower") );
    registerFunction"upper"new StandardSQLFunction("upper") );
    registerFunction"str"new StandardSQLFunction("str", Hibernate.STRING) );
    registerFunction"ltrim"new StandardSQLFunction("ltrim") );
    registerFunction"rtrim"new StandardSQLFunction("rtrim") );
    registerFunction"reverse"new StandardSQLFunction("reverse") );
    registerFunction"space"new StandardSQLFunction("space", Hibernate.STRING) );

    registerFunction"user"new NoArgSQLFunction("user", Hibernate.STRING) );

    registerFunction"current_timestamp"new NoArgSQLFunction("getdate", Hibernate.TIMESTAMP) );
    registerFunction"current_time"new NoArgSQLFunction("getdate", Hibernate.TIME) );
    registerFunction"current_date"new NoArgSQLFunction("getdate", Hibernate.DATE) );

    registerFunction"getdate"new NoArgSQLFunction("getdate", Hibernate.TIMESTAMP) );
    registerFunction"getutcdate"new NoArgSQLFunction("getutcdate", Hibernate.TIMESTAMP) );
    registerFunction"day"new StandardSQLFunction("day", Hibernate.INTEGER) );
    registerFunction"month"new StandardSQLFunction("month", Hibernate.INTEGER) );
    registerFunction"year"new StandardSQLFunction("year", Hibernate.INTEGER) );
    registerFunction"datename"new StandardSQLFunction("datename", Hibernate.STRING) );

    registerFunction"abs"new StandardSQLFunction("abs") );
    registerFunction"sign"new StandardSQLFunction("sign", Hibernate.INTEGER) );

    registerFunction"acos"new StandardSQLFunction("acos", Hibernate.DOUBLE) );
    registerFunction"asin"new StandardSQLFunction("asin", Hibernate.DOUBLE) );
    registerFunction"atan"new StandardSQLFunction("atan", Hibernate.DOUBLE) );
    registerFunction"cos"new StandardSQLFunction("cos", Hibernate.DOUBLE) );
    registerFunction"cot"new StandardSQLFunction("cot", Hibernate.DOUBLE) );
    registerFunction"exp"new StandardSQLFunction("exp", Hibernate.DOUBLE) );
    registerFunction"log"new StandardSQLFunction"log", Hibernate.DOUBLE) );
    registerFunction"log10"new StandardSQLFunction("log10", Hibernate.DOUBLE) );
    registerFunction"sin"new StandardSQLFunction("sin", Hibernate.DOUBLE) );
    registerFunction"sqrt"new StandardSQLFunction("sqrt", Hibernate.DOUBLE) );
    registerFunction"tan"new StandardSQLFunction("tan", Hibernate.DOUBLE) );
    registerFunction"pi"new NoArgSQLFunction("pi", Hibernate.DOUBLE) );
    registerFunction"square"new StandardSQLFunction("square") );
    registerFunction"rand"new StandardSQLFunction("rand", Hibernate.FLOAT) );

    registerFunction("radians"new StandardSQLFunction("radians", Hibernate.DOUBLE) );
    registerFunction("degrees"new StandardSQLFunction("degrees", Hibernate.DOUBLE) );

    registerFunction"round"new StandardSQLFunction("round") );
    registerFunction"ceiling"new StandardSQLFunction("ceiling") );
    registerFunction"floor"new StandardSQLFunction("floor") );

    registerFunction"isnull"new StandardSQLFunction("isnull") );

    registerFunction"concat"new VarArgsSQLFunctionHibernate.STRING, "(","+",")" ) );

    registerFunction"length"new StandardSQLFunction"len", Hibernate.INTEGER ) );
    registerFunction"trim"new SQLFunctionTemplateHibernate.STRING, "ltrim(rtrim(?1))") );
    registerFunction"locate"new CharIndexFunction() );

    getDefaultProperties().setProperty(Environment.STATEMENT_BATCH_SIZE, NO_BATCH);
  }

  public String getAddColumnString() {
    return "add";
  }
  public String getNullColumnString() {
    return " null";
  }
  public boolean qualifyIndexName() {
    return false;
  }

  public String getForUpdateString() {
    return "";
  }

  public boolean supportsIdentityColumns() {
    return true;
  }
  public String getIdentitySelectString() {
    return "select @@identity";
  }
  public String getIdentityColumnString() {
    return "identity not null"//starts with 1, implicitly
  }

  public boolean supportsInsertSelectIdentity() {
    return true;
  }

  public String appendIdentitySelectToInsert(String insertSQL) {
    return insertSQL + "\nselect @@identity";
  }

  public String appendLockHint(LockMode mode, String tableName) {
    if mode.greaterThanLockMode.READ ) ) {
      return tableName + " holdlock";
    }
    else {
      return tableName;
    }
  }

  public String applyLocksToSql(String sql, Map aliasedLockModes, Map keyColumnNames) {
    Iterator itr = aliasedLockModes.entrySet().iterator();
    StringBuffer buffer = new StringBuffersql );
    int correction = 0;
    while itr.hasNext() ) {
      final Map.Entry entry = Map.Entry itr.next();
      final LockMode lockMode = LockMode entry.getValue();
      if lockMode.greaterThanLockMode.READ ) ) {
        final String alias = String entry.getKey();
        int start = -1, end = -1;
        if sql.endsWith" " + alias ) ) {
          start = sql.length() - alias.length() ) + correction;
          end = start + alias.length();
        }
        else {
          int position = sql.indexOf" " + alias + " " );
          if position <= -) {
            position = sql.indexOf" " + alias + "," );
          }
          if position > -) {
            start = position + correction + 1;
            end = start + alias.length();
          }
        }

        if start > -) {
          final String lockHint = appendLockHintlockMode, alias );
          buffer.replacestart, end, lockHint );
          correction += lockHint.length() - alias.length() );
        }
      }
    }
    return buffer.toString();
  }

  public int registerResultSetOutParameter(CallableStatement statement, int colthrows SQLException {
    return col; // sql server just returns automatically
  }

  public ResultSet getResultSet(CallableStatement psthrows SQLException {
    boolean isResultSet = ps.execute();
//     This assumes you will want to ignore any update counts
    while !isResultSet && ps.getUpdateCount() != -) {
      isResultSet = ps.getMoreResults();
    }
//     You may still have other ResultSets or update counts left to process here
//     but you can't do it now or the ResultSet you just got will be closed
    return ps.getResultSet();
  }

  public boolean supportsCurrentTimestampSelection() {
    return true;
  }

  public boolean isCurrentTimestampSelectStringCallable() {
    return false;
  }

  public String getCurrentTimestampSelectString() {
    return "select getdate()";
  }

  public boolean supportsTemporaryTables() {
    return true;
  }

  public String generateTemporaryTableName(String baseTableName) {
    return "#" + baseTableName;
  }

  public boolean dropTemporaryTableAfterUse() {
    return true;  // sql-server, at least needed this dropped after use; strange!
  }


  // Overridden informational metadata ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

  public boolean supportsEmptyInList() {
    return false;
  }

  public boolean supportsExistsInSelect() {
    return false;
  }

  public boolean doesReadCommittedCauseWritersToBlockReaders() {
    return true;
  }

  public boolean doesRepeatableReadCauseReadersToBlockWriters() {
    return true;
  }
}