Java UnparsedSql类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中liquibase.sql.UnparsedSql类的典型用法代码示例。如果您正苦于以下问题：Java UnparsedSql类的具体用法？Java UnparsedSql怎么用？Java UnparsedSql使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

UnparsedSql类属于liquibase.sql包，在下文中一共展示了UnparsedSql类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(GetViewDefinitionStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    try {
        String sql = "select view_definition from information_schema.views where upper(table_name)='" + statement.getViewName().toUpperCase() + "'";
        if (database.convertRequestedSchemaToCatalog(statement.getSchemaName()) != null) {
            sql += " and table_schema='" + database.convertRequestedSchemaToSchema(statement.getSchemaName()) + "'";
        } else if (database.convertRequestedSchemaToCatalog(statement.getSchemaName()) != null) {
            sql += " and table_catalog='" + database.convertRequestedSchemaToCatalog(statement.getSchemaName()) + "'";
        }

        return new Sql[] {
                new UnparsedSql(sql)
        };
    } catch (DatabaseException e) {
        throw new UnexpectedLiquibaseException(e);
    }
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:17，代码来源:GetViewDefinitionGenerator.java

示例2: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(CreateViewStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    String createClause;

    if (database instanceof FirebirdDatabase) {
        if (statement.isReplaceIfExists()) {
            createClause = "RECREATE VIEW";
        } else {
            createClause = "RECREATE VIEW";
        }
    } else if (database instanceof SybaseASADatabase && statement.getSelectQuery().toLowerCase().startsWith("create view")) {
        // Sybase ASA saves view definitions with header.
        return new Sql[]{
                new UnparsedSql(statement.getSelectQuery())
        };
    } else {
        createClause = "CREATE " + (statement.isReplaceIfExists() ? "OR REPLACE " : "") + "VIEW";
    }

    return new Sql[]{
            new UnparsedSql(createClause + " " + database.escapeViewName(statement.getSchemaName(), statement.getViewName()) + " AS " + statement.getSelectQuery())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:23，代码来源:CreateViewGenerator.java

示例3: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(FindForeignKeyConstraintsStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    StringBuilder sb = new StringBuilder();

    sb.append("SELECT ");
    sb.append("RC.TABLE_NAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_NAME).append(", ");
    sb.append("KCU.COLUMN_NAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_COLUMN_NAME).append(", ");
    sb.append("RC.REFERENCED_TABLE_NAME ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_TABLE_NAME).append(", ");
    sb.append("KCU.REFERENCED_COLUMN_NAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_COLUMN_NAME).append(", ");
    sb.append("RC.CONSTRAINT_NAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_CONSTRAINT_NAME).append(" ");
    sb.append("FROM INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS RC,");
    sb.append("     INFORMATION_SCHEMA.KEY_COLUMN_USAGE KCU ");
    sb.append("WHERE RC.TABLE_NAME = KCU.TABLE_NAME ");
    sb.append("AND RC.CONSTRAINT_SCHEMA = KCU.CONSTRAINT_SCHEMA ");
    sb.append("AND RC.CONSTRAINT_NAME = KCU.CONSTRAINT_NAME ");
    sb.append("AND RC.TABLE_NAME = '").append(statement.getBaseTableName()).append("' ");
    try {
        sb.append("AND RC.CONSTRAINT_SCHEMA = '").append(database.convertRequestedSchemaToSchema(null)).append("'");
    } catch (DatabaseException e) {
        throw new UnexpectedLiquibaseException(e);
    }
    return new Sql[]{
            new UnparsedSql(sb.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:25，代码来源:FindForeignKeyConstraintsGeneratorMySQL.java

示例4: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(FindForeignKeyConstraintsStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    StringBuilder sb = new StringBuilder();

    sb.append("SELECT ");
    sb.append("TABNAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_NAME).append(", ");
    sb.append("PK_COLNAMES as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_COLUMN_NAME).append(", ");
    sb.append("REFTABNAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_TABLE_NAME).append(", ");
    sb.append("FK_COLNAMES as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_COLUMN_NAME).append(",");
    sb.append("CONSTNAME as ").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_CONSTRAINT_NAME).append(" ");
    sb.append("FROM SYSCAT.REFERENCES ");
    sb.append("WHERE TABNAME='").append(statement.getBaseTableName()).append("'");

    return new Sql[]{
            new UnparsedSql(sb.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:17，代码来源:FindForeignKeyConstraintsGeneratorDB2.java

示例5: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
@Override
public Sql[] generateSql(AddUniqueConstraintStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {

	final String sqlNoContraintNameTemplate = "ALTER TABLE %s ADD CONSTRAINT UNIQUE (%s)";
	final String sqlTemplate = "ALTER TABLE %s ADD CONSTRAINT UNIQUE (%s) CONSTRAint %s";
	if (statement.getConstraintName() == null) {
		return new Sql[] {
			new UnparsedSql(String.format(sqlNoContraintNameTemplate 
					, database.escapeTableName(statement.getSchemaName(), statement.getTableName())
					, database.escapeColumnNameList(statement.getColumnNames())
			))
		};
	} else {
		return new Sql[] {
			new UnparsedSql(String.format(sqlTemplate
					, database.escapeTableName(statement.getSchemaName(), statement.getTableName())
					, database.escapeColumnNameList(statement.getColumnNames())
					, database.escapeConstraintName(statement.getConstraintName())
			))
		};
	}


	
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:26，代码来源:AddUniqueConstraintGeneratorInformix.java

示例6: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(SelectFromDatabaseChangeLogLockStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
  	String liquibaseSchema;
 		liquibaseSchema = database.getLiquibaseSchemaName();

String[] columns = statement.getColumnsToSelect();
int numberOfColumns = columns.length;
String[] escapedColumns = new String[numberOfColumns];
for (int i=0; i<numberOfColumns; i++) {
	escapedColumns[i] = database.escapeColumnName(liquibaseSchema, database.getDatabaseChangeLogLockTableName(), columns[i]);
}

      String sql = "SELECT " + StringUtils.join(escapedColumns, ",") + " FROM " +
              database.escapeTableName(liquibaseSchema, database.getDatabaseChangeLogLockTableName()) +
              " WHERE " + database.escapeColumnName(liquibaseSchema, database.getDatabaseChangeLogLockTableName(), "ID") + "=1";

      if (database instanceof OracleDatabase) {
          sql += " FOR UPDATE";
      }
      return new Sql[] {
              new UnparsedSql(sql)
      };
  }

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:23，代码来源:SelectFromDatabaseChangeLogLockGenerator.java

示例7: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(AddPrimaryKeyStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    String sql;
    if (statement.getConstraintName() == null  || database instanceof MySQLDatabase || database instanceof SybaseASADatabase) {
        sql = "ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " ADD PRIMARY KEY (" + database.escapeColumnNameList(statement.getColumnNames()) + ")";
    } else {
        sql = "ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " ADD CONSTRAINT " + database.escapeConstraintName(statement.getConstraintName()) + " PRIMARY KEY (" + database.escapeColumnNameList(statement.getColumnNames()) + ")";
    }

    if (StringUtils.trimToNull(statement.getTablespace()) != null && database.supportsTablespaces()) {
        if (database instanceof MSSQLDatabase) {
            sql += " ON "+statement.getTablespace();
        } else if (database instanceof DB2Database || database instanceof SybaseASADatabase) {
            ; //not supported
        } else {
            sql += " USING INDEX TABLESPACE "+statement.getTablespace();
        }
    }

    return new Sql[] {
            new UnparsedSql(sql)
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:23，代码来源:AddPrimaryKeyGenerator.java

示例8: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
@Override
public Sql[] generateSql(
		AddAutoIncrementStatement statement,
		Database database,
		SqlGeneratorChain sqlGeneratorChain) {
    return new Sql[]{
        new UnparsedSql(
        	"ALTER TABLE "
        		+ database.escapeTableName(statement.getSchemaName(), statement.getTableName())
        		+ " ALTER COLUMN "
        		+ database.escapeColumnName(
        			statement.getSchemaName(),
        			statement.getTableName(),
        			statement.getColumnName())
        		+ " SET "
        		+ database.getAutoIncrementClause(
        			statement.getStartWith(), statement.getIncrementBy()),
            new Column()
                .setTable(
                	new Table(statement.getTableName()).setSchema(statement.getSchemaName()))
                .setName(statement.getColumnName()))
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:24，代码来源:AddAutoIncrementGeneratorDB2.java

示例9: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(CopyRowsStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    StringBuffer sql = new StringBuffer();
    if (database instanceof SQLiteDatabase) {
        sql.append("INSERT INTO `").append(statement.getTargetTable()).append("` SELECT ");
        for (int i = 0; i < statement.getCopyColumns().size(); i++) {
            ColumnConfig column = statement.getCopyColumns().get(i);
            if (i > 0) {
                sql.append(",");
            }
            sql.append("`").append(column.getName()).append("`");
        }
        sql.append(" FROM `").append(statement.getSourceTable()).append("`");
    }

    return new Sql[]{
            new UnparsedSql(sql.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:19，代码来源:CopyRowsGenerator.java

示例10: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(CreateDatabaseChangeLogTableStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    return new Sql[] {
            new UnparsedSql("CREATE TABLE " + database.escapeTableName(database.getDefaultSchemaName(), database.getDatabaseChangeLogTableName()) + " (ID VARCHAR(150) NOT NULL, " +
            "AUTHOR VARCHAR(150) NOT NULL, " +
            "FILENAME VARCHAR(255) NOT NULL, " +
            "DATEEXECUTED " + TypeConverterFactory.getInstance().findTypeConverter(database).getDateTimeType() + " NOT NULL, " +
            "ORDEREXECUTED INT NOT NULL, " +
            "EXECTYPE VARCHAR(10) NOT NULL, " +
            "MD5SUM VARCHAR(35) NULL, " +
            "DESCRIPTION VARCHAR(255) NULL, " +
            "COMMENTS VARCHAR(255) NULL, " +
            "TAG VARCHAR(255) NULL, " +
            "LIQUIBASE VARCHAR(20) NULL, " +
            "PRIMARY KEY(ID, AUTHOR, FILENAME))")
    };  //To change body of implemented methods use File | Settings | File Templates.
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:17，代码来源:CreateDatabaseChangeLogTableGeneratorSybase.java

示例11: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(DropTableStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    StringBuffer buffer = new StringBuffer();
    buffer.append("DROP TABLE ").append(database.escapeTableName(statement.getSchemaName(), statement.getTableName()));
    if (statement.isCascadeConstraints()) {
        if (!database.supportsDropTableCascadeConstraints()) {
            LogFactory.getLogger().warning("Database does not support drop with cascade");
        } else if (database instanceof OracleDatabase) {
            buffer.append(" CASCADE CONSTRAINTS");
        } else {
            buffer.append(" CASCADE");
        }
    }

    return new Sql[]{
            new UnparsedSql(buffer.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:18，代码来源:DropTableGenerator.java

示例12: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(FindForeignKeyConstraintsStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
     StringBuilder sb = new StringBuilder();

        sb.append("SELECT ");
        sb.append("FK.TABLE_NAME as \"").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_NAME).append("\", ");
        sb.append("CU.COLUMN_NAME as \"").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_BASE_TABLE_COLUMN_NAME).append("\", ");
        sb.append("PK.TABLE_NAME as \"").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_TABLE_NAME).append("\", ");
        sb.append("PT.COLUMN_NAME as \"").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_FOREIGN_COLUMN_NAME).append("\", ");
        sb.append("C.CONSTRAINT_NAME as \"").append(FindForeignKeyConstraintsStatement.RESULT_COLUMN_CONSTRAINT_NAME).append("\" ");
        sb.append("FROM       INFORMATION_SCHEMA.REFERENTIAL_CONSTRAINTS C ");
        sb.append("INNER JOIN  INFORMATION_SCHEMA.TABLE_CONSTRAINTS FK ON C.CONSTRAINT_NAME = FK.CONSTRAINT_NAME ");
        sb.append("INNER JOIN      INFORMATION_SCHEMA.TABLE_CONSTRAINTS PK ON C.UNIQUE_CONSTRAINT_NAME = PK.CONSTRAINT_NAME ");
        sb.append("INNER JOIN      INFORMATION_SCHEMA.KEY_COLUMN_USAGE CU ON C.CONSTRAINT_NAME = CU.CONSTRAINT_NAME ");
        sb.append("INNER JOIN  ( ");
        sb.append("  SELECT      i1.TABLE_NAME, i2.COLUMN_NAME ");
        sb.append("  FROM        INFORMATION_SCHEMA.TABLE_CONSTRAINTS i1 ");
        sb.append("  INNER JOIN      INFORMATION_SCHEMA.KEY_COLUMN_USAGE i2 ON i1.CONSTRAINT_NAME = i2.CONSTRAINT_NAME ");
        sb.append("  WHERE       i1.CONSTRAINT_TYPE = 'PRIMARY KEY' ");
        sb.append(") PT ON PT.TABLE_NAME = PK.TABLE_NAME ");
        sb.append("WHERE      lower(FK.TABLE_NAME)='").append(statement.getBaseTableName().toLowerCase()).append("'");

    return new Sql[] {
            new UnparsedSql(sb.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:26，代码来源:FindForeignKeyConstraintsGeneratorPostgres.java

示例13: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(DropIndexStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
      List<String> associatedWith = StringUtils.splitAndTrim(statement.getAssociatedWith(), ",");
      if (associatedWith != null) {
          if (associatedWith.contains(Index.MARK_PRIMARY_KEY)|| associatedWith.contains(Index.MARK_UNIQUE_CONSTRAINT)) {
              return new Sql[0];
          } else if (associatedWith.contains(Index.MARK_FOREIGN_KEY) ) {
              if (!(database instanceof OracleDatabase || database instanceof MSSQLDatabase)) {
                  return new Sql[0];
              }
          }
      }

      String schemaName = statement.getTableSchemaName();
      
      if (database instanceof MySQLDatabase) {
          return new Sql[] {new UnparsedSql("DROP INDEX " + database.escapeIndexName(null, statement.getIndexName()) + " ON " + database.escapeTableName(schemaName, statement.getTableName())) };
      } else if (database instanceof MSSQLDatabase) {
          return new Sql[] {new UnparsedSql("DROP INDEX " + database.escapeTableName(schemaName, statement.getTableName()) + "." + database.escapeIndexName(null, statement.getIndexName())) };
      } else if (database instanceof PostgresDatabase) {
	return new Sql[]{new UnparsedSql("DROP INDEX " + database.escapeIndexName(schemaName, statement.getIndexName()))};
}

      return new Sql[] {new UnparsedSql("DROP INDEX " + database.escapeIndexName(schemaName, statement.getIndexName())) };
  }

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:25，代码来源:DropIndexGenerator.java

示例14: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(UpdateStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    StringBuffer sql = new StringBuffer("UPDATE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " SET");
    for (String column : statement.getNewColumnValues().keySet()) {
        sql.append(" ").append(database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), column)).append(" = ");
        sql.append(convertToString(statement.getNewColumnValues().get(column), database));
        sql.append(",");
    }

    sql.deleteCharAt(sql.lastIndexOf(","));
    if (statement.getWhereClause() != null) {
        String fixedWhereClause = "WHERE " + statement.getWhereClause().trim();
        for (Object param : statement.getWhereParameters()) {
            fixedWhereClause = fixedWhereClause.replaceFirst("\\?", convertToString(param, database));
        }
        sql.append(" ").append(fixedWhereClause);
    }

    return new Sql[]{
            new UnparsedSql(sql.toString())
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:22，代码来源:UpdateGenerator.java

示例15: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(RenameColumnStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    String sql;
    if (database instanceof MSSQLDatabase) {
    	// do no escape the new column name. Otherwise it produce "exec sp_rename '[dbo].[person].[usernae]', '[username]'"
        sql = "exec sp_rename '" + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + "." + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + "', '" + statement.getNewColumnName() + "'";
    } else if (database instanceof MySQLDatabase) {
        sql ="ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " CHANGE " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName()) + " " + statement.getColumnDataType();
    } else if (database instanceof HsqlDatabase || database  instanceof H2Database) {
        sql ="ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " ALTER COLUMN " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " RENAME TO " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName());
    } else if (database instanceof FirebirdDatabase) {
        sql = "ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " ALTER COLUMN " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " TO " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName());
    } else if ((database instanceof MaxDBDatabase)
            // supported in Derby from version 10.3.1.4 (see "http://issues.apache.org/jira/browse/DERBY-1490")
            || (database instanceof DerbyDatabase)
            || (database instanceof InformixDatabase)) {
      sql = "RENAME COLUMN " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + "." + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " TO " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName());
    } else if (database instanceof SybaseASADatabase) {
        sql = "ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " RENAME " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " TO " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName());
    } else {
        sql = "ALTER TABLE " + database.escapeTableName(statement.getSchemaName(), statement.getTableName()) + " RENAME COLUMN " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getOldColumnName()) + " TO " + database.escapeColumnName(statement.getSchemaName(), statement.getTableName(), statement.getNewColumnName());
    }

    return new Sql[] {
            new UnparsedSql(sql)
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:27，代码来源:RenameColumnGenerator.java

示例16: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(SelectSequencesStatement statement,
		Database database, SqlGeneratorChain sqlGeneratorChain)
{
    try {
    	String schemaName = database.convertRequestedSchemaToSchema(
    			statement.getSchemaName());
        return new Sql[] {
                new UnparsedSql(
                		"SELECT " +
                		"  seq.SEQUENCENAME AS SEQUENCE_NAME " +
                		"FROM " +
                		"  SYS.SYSSEQUENCES seq, " +
                		"  SYS.SYSSCHEMAS sch " +
                		"WHERE " +
                		"  sch.SCHEMANAME = '" + schemaName + "' AND " +
                		"  sch.SCHEMAID = seq.SCHEMAID")
        };
    } catch (DatabaseException e) {
        throw new UnexpectedLiquibaseException(e);
    }
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:22，代码来源:SelectSequencesGeneratorDerby.java

示例17: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
@Override
public Sql[] generateSql(
		AddAutoIncrementStatement statement,
		Database database,
		SqlGeneratorChain sqlGeneratorChain) {
    return new Sql[]{
        new UnparsedSql(
        	"ALTER TABLE "
        		+ database.escapeTableName(statement.getSchemaName(), statement.getTableName())
        		+ " ALTER COLUMN "
        		+ database.escapeColumnName(
        			statement.getSchemaName(),
        			statement.getTableName(),
        			statement.getColumnName())
        		+ " "
        		+ statement.getColumnDataType()
        		+ " "
        		+ database.getAutoIncrementClause(
        			statement.getStartWith(), statement.getIncrementBy()),
            new Column()
                .setTable(
                	new Table(statement.getTableName()).setSchema(statement.getSchemaName()))
                .setName(statement.getColumnName()))
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:26，代码来源:AddAutoIncrementGeneratorHsqlH2.java

示例18: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(
		AddAutoIncrementStatement statement,
		Database database,
		SqlGeneratorChain sqlGeneratorChain) {
    String sql = "ALTER TABLE "
        + database.escapeTableName(statement.getSchemaName(), statement.getTableName())
        + " MODIFY "
        + database.escapeColumnName(
        	statement.getSchemaName(), statement.getTableName(), statement.getColumnName())
        + " "
        + TypeConverterFactory.getInstance().findTypeConverter(database).getDataType(
        	statement.getColumnDataType(), true)
        + " " 
        + database.getAutoIncrementClause(statement.getStartWith(), statement.getIncrementBy());

    return new Sql[]{
        new UnparsedSql(sql, new Column()
            .setTable(new Table(statement.getTableName()).setSchema(statement.getSchemaName()))
            .setName(statement.getColumnName()))
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:22，代码来源:AddAutoIncrementGenerator.java

示例19: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(RenameViewStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    String sql;

    if (database instanceof MSSQLDatabase) {
        sql = "exec sp_rename '" + database.escapeViewName(statement.getSchemaName(), statement.getOldViewName()) + "', '" + statement.getNewViewName() + '\'';
    } else if (database instanceof MySQLDatabase) {
        sql = "RENAME TABLE " + database.escapeViewName(statement.getSchemaName(), statement.getOldViewName()) + " TO " + database.escapeViewName(statement.getSchemaName(), statement.getNewViewName());
    } else if (database instanceof PostgresDatabase) {
        sql = "ALTER TABLE " + database.escapeViewName(statement.getSchemaName(), statement.getOldViewName()) + " RENAME TO " + database.escapeViewName(null, statement.getNewViewName());
    } else if (database instanceof MaxDBDatabase) {
        sql = "RENAME VIEW " + database.escapeViewName(statement.getSchemaName(), statement.getOldViewName()) + " TO " + database.escapeViewName(null, statement.getNewViewName());
    } else {
        sql = "RENAME " + database.escapeViewName(statement.getSchemaName(), statement.getOldViewName()) + " TO " + database.escapeViewName(null, statement.getNewViewName());
    }

    return new Sql[]{
            new UnparsedSql(sql)
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:20，代码来源:RenameViewGenerator.java

示例20: generateSql

import liquibase.sql.UnparsedSql; //导入依赖的package包/类
public Sql[] generateSql(SelectFromDatabaseChangeLogStatement statement, Database database, SqlGeneratorChain sqlGeneratorChain) {
    String sql = "SELECT " + StringUtils.join(statement.getColumnsToSelect(), ",").toUpperCase() + " FROM " +
            database.escapeTableName(database.getLiquibaseSchemaName(), database.getDatabaseChangeLogTableName());

    SelectFromDatabaseChangeLogStatement.WhereClause whereClause = statement.getWhereClause();
    if (whereClause != null) {
        if (whereClause instanceof SelectFromDatabaseChangeLogStatement.ByTag) {
            sql += " WHERE TAG='" + ((SelectFromDatabaseChangeLogStatement.ByTag) whereClause).getTagName() + "'";
        } else if (whereClause instanceof SelectFromDatabaseChangeLogStatement.ByNotNullCheckSum) {
                sql += " WHERE MD5SUM IS NOT NULL";
        } else {
            throw new UnexpectedLiquibaseException("Unknown where clause type: " + whereClause.getClass().getName());
        }
    }

    if (statement.getOrderByColumns() != null && statement.getOrderByColumns().length > 0) {
        sql += " ORDER BY "+StringUtils.join(statement.getOrderByColumns(), ", ").toUpperCase();
    }

    return new Sql[]{
            new UnparsedSql(sql)
    };
}

开发者ID:hongliangpan，项目名称:manydesigns.cn，代码行数:24，代码来源:SelectFromDatabaseChangeLogGenerator.java

注：本文中的liquibase.sql.UnparsedSql类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java MimeLookup类代码示例发布时间：2022-05-22

Java QueryTimeoutException类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18279|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9678|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8180|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8458|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9393|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8431|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java UnparsedSql类代码示例

示例1: generateSql

示例2: generateSql

示例3: generateSql

示例4: generateSql

示例5: generateSql

示例6: generateSql

示例7: generateSql

示例8: generateSql

示例9: generateSql

示例10: generateSql

示例11: generateSql

示例12: generateSql

示例13: generateSql

示例14: generateSql

示例15: generateSql

示例16: generateSql

示例17: generateSql

示例18: generateSql

示例19: generateSql

示例20: generateSql

请发表评论

全部评论

上一篇：

下一篇：

solegalli/feature-selection-for-machine-

lunasoldstuff/bridge: mastodon bridge

win7系统重装系统初始设置的操作方法

钱可通神的意思?钱可通神成语典故

CVE-2022-35629

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053