package liquibase.sqlgenerator.core;

 import liquibase.database.Database;

 import liquibase.database.typeconversion.TypeConverterFactory;

 import liquibase.exception.ValidationErrors;

 import liquibase.sql.Sql;

 import liquibase.sqlgenerator.SqlGenerator;

 import liquibase.sqlgenerator.SqlGeneratorChain;

 import liquibase.sqlgenerator.SqlGeneratorFactory;

 import liquibase.statement.NotNullConstraint;

 import liquibase.statement.core.CreateDatabaseChangeLogLockTableStatement;

 import liquibase.statement.core.CreateTableStatement;

 import liquibase.statement.core.InsertStatement;

 import java.util.ArrayList;

 import java.util.Arrays;

 import java.util.List;

 public class CreateDatabaseChangeLogLockTableGenerator extends

         AbstractSqlGenerator<CreateDatabaseChangeLogLockTableStatement> {

     public ValidationErrors validate(

             CreateDatabaseChangeLogLockTableStatement createDatabaseChangeLogLockTableStatement, Database database,

             SqlGeneratorChain sqlGeneratorChain) {

         return new ValidationErrors();

     }

     public Sql[] generateSql(CreateDatabaseChangeLogLockTableStatement statement, Database database,

             SqlGeneratorChain sqlGeneratorChain) {

         CreateTableStatement createTableStatement = new CreateTableStatement(database.getLiquibaseSchemaName(),

                 database.getDatabaseChangeLogLockTableName())

                 .addPrimaryKeyColumn("ID",

                         TypeConverterFactory.getInstance().findTypeConverter(database).getDataType("INT", false), null,

                         null, null, new NotNullConstraint())

                 .addColumn("LOCKED",

                         TypeConverterFactory.getInstance().findTypeConverter(database).getDataType("BOOLEAN", false),

                         null, new NotNullConstraint())

                 .addColumn("LOCKGRANTED",

                         TypeConverterFactory.getInstance().findTypeConverter(database).getDataType("DATETIME", false))

                 .addColumn(

                         "LOCKEDBY",

                         TypeConverterFactory.getInstance().findTypeConverter(database)

                                 .getDataType("VARCHAR(255)", false));

         InsertStatement insertStatement = new InsertStatement(database.getLiquibaseSchemaName(),

                 database.getDatabaseChangeLogLockTableName()).addColumnValue("ID", 1).addColumnValue("LOCKED",

                 Boolean.FALSE);

         List<Sql> sql = new ArrayList<Sql>();

         sql.addAll(Arrays.asList(SqlGeneratorFactory.getInstance().generateSql(createTableStatement, database)));

         sql.addAll(Arrays.asList(SqlGeneratorFactory.getInstance().generateSql(insertStatement, database)));

         return sql.toArray(new Sql[sql.size()]);

     }

 }