1 |
|
package liquibase.statementexecute; |
2 |
|
|
3 |
|
import liquibase.database.Database; |
4 |
|
import liquibase.database.core.MSSQLDatabase; |
5 |
|
import liquibase.database.core.MaxDBDatabase; |
6 |
|
import liquibase.database.core.MySQLDatabase; |
7 |
|
import liquibase.database.core.PostgresDatabase; |
8 |
|
import liquibase.database.core.SQLiteDatabase; |
9 |
|
import liquibase.database.core.SybaseASADatabase; |
10 |
|
import liquibase.database.core.SybaseDatabase; |
11 |
|
import liquibase.database.core.CacheDatabase; |
12 |
|
import liquibase.database.core.*; |
13 |
|
import liquibase.database.typeconversion.TypeConverterFactory; |
14 |
|
import liquibase.test.TestContext; |
15 |
|
import liquibase.test.DatabaseTestContext; |
16 |
|
import liquibase.statement.*; |
17 |
|
import liquibase.statement.core.AddColumnStatement; |
18 |
|
import liquibase.statement.core.CreateTableStatement; |
19 |
|
import liquibase.sqlgenerator.SqlGeneratorFactory; |
20 |
|
import liquibase.sql.Sql; |
21 |
|
|
22 |
|
import java.util.List; |
23 |
|
import java.util.ArrayList; |
24 |
|
|
25 |
|
import org.junit.Test; |
26 |
|
|
|
|
| 0% |
Uncovered Elements: 47 (47) |
Complexity: 6 |
Complexity Density: 0.15 |
|
27 |
|
public class AddColumnExecutorTest extends AbstractExecuteTest { |
28 |
|
|
29 |
|
protected static final String TABLE_NAME = "table_name"; |
30 |
|
|
|
|
| 0% |
Uncovered Elements: 11 (11) |
Complexity: 2 |
Complexity Density: 0.22 |
|
31 |
0
|
@Override... |
32 |
|
protected List<? extends SqlStatement> setupStatements(Database database) { |
33 |
0
|
ArrayList<CreateTableStatement> statements = new ArrayList<CreateTableStatement>(); |
34 |
0
|
CreateTableStatement table = new CreateTableStatement(null, TABLE_NAME); |
35 |
0
|
table.addColumn("id", TypeConverterFactory.getInstance().findTypeConverter(database).getDataType("int", false), null, new NotNullConstraint()); |
36 |
0
|
statements.add(table); |
37 |
|
|
38 |
0
|
if (database.supportsSchemas()) { |
39 |
0
|
table = new CreateTableStatement(DatabaseTestContext.ALT_SCHEMA, TABLE_NAME); |
40 |
0
|
table.addColumn("id", TypeConverterFactory.getInstance().findTypeConverter(database).getDataType("int", false), null, new NotNullConstraint()); |
41 |
0
|
statements.add(table); |
42 |
|
} |
43 |
0
|
return statements; |
44 |
|
} |
45 |
|
|
|
|
| 0% |
Uncovered Elements: 8 (8) |
Complexity: 1 |
Complexity Density: 0.12 |
4
-
|
|
46 |
0
|
@SuppressWarnings("unchecked")... |
47 |
|
@Test |
48 |
|
public void generateSql_autoIncrement() throws Exception { |
49 |
0
|
this.statementUnderTest = new AddColumnStatement(null, "table_name", "column_name", "int", null, new AutoIncrementConstraint("column_name")); |
50 |
|
|
51 |
0
|
assertCorrect("alter table table_name add column_name serial", InformixDatabase.class); |
52 |
0
|
assertCorrect("alter table [table_name] add [column_name] int default autoincrement null", SybaseASADatabase.class); |
53 |
0
|
assertCorrect("alter table [table_name] add [column_name] serial", PostgresDatabase.class); |
54 |
0
|
assertCorrect("alter table [dbo].[table_name] add [column_name] int identity", MSSQLDatabase.class); |
55 |
0
|
assertCorrect("alter table [table_name] add [column_name] int identity null", SybaseDatabase.class); |
56 |
0
|
assertCorrect("not supported. fixme!!", SQLiteDatabase.class); |
57 |
0
|
assertCorrect("alter table table_name add column_name int auto_increment_clause"); |
58 |
|
} |
59 |
|
|
|
|
| 0% |
Uncovered Elements: 8 (8) |
Complexity: 1 |
Complexity Density: 0.12 |
4
-
|
|
60 |
0
|
@SuppressWarnings("unchecked")... |
61 |
|
@Test |
62 |
|
public void generateSql_notNull() throws Exception { |
63 |
0
|
this.statementUnderTest = new AddColumnStatement(null, "table_name", "column_name", "int", 42, new NotNullConstraint()); |
64 |
0
|
assertCorrect("alter table [table_name] add [column_name] int not null default 42", CacheDatabase.class, MaxDBDatabase.class); |
65 |
0
|
assertCorrect("alter table [table_name] add [column_name] int default 42 not null", SybaseASADatabase.class, SybaseDatabase.class); |
66 |
0
|
assertCorrect("alter table table_name add column_name int not null default 42", PostgresDatabase.class); |
67 |
0
|
assertCorrect("alter table [dbo].[table_name] add [column_name] int not null constraint df_table_name_column_name default 42", MSSQLDatabase.class); |
68 |
0
|
assertCorrect("alter table `table_name` add `column_name` int not null default 42", MySQLDatabase.class); |
69 |
0
|
assertCorrect("not supported. fixme!!", SQLiteDatabase.class); |
70 |
0
|
assertCorrect("ALTER TABLE [table_name] ADD [column_name] int DEFAULT 42 NOT NULL"); |
71 |
|
} |
72 |
|
|
|
|
| 0% |
Uncovered Elements: 7 (7) |
Complexity: 1 |
Complexity Density: 0.14 |
4
-
|
|
73 |
0
|
@SuppressWarnings("unchecked")... |
74 |
|
@Test |
75 |
|
public void generateSql_primaryKey() throws Exception { |
76 |
0
|
this.statementUnderTest = new AddColumnStatement(null, "table_name", "column_name", "int", null, new PrimaryKeyConstraint()); |
77 |
|
|
78 |
0
|
assertCorrect("alter table [table_name] add [column_name] int not null primary key", HsqlDatabase.class, MaxDBDatabase.class); |
79 |
0
|
assertCorrect("alter table [table_name] add [column_name] int primary key not null", SybaseASADatabase.class, SybaseDatabase.class); |
80 |
0
|
assertCorrect("alter table [dbo].[table_name] add [column_name] int not null primary key", MSSQLDatabase.class); |
81 |
0
|
assertCorrect("alter table table_name add column_name int not null primary key", PostgresDatabase.class); |
82 |
0
|
assertCorrect("alter table `table_name` add `column_name` int not null primary key", MySQLDatabase.class); |
83 |
0
|
assertCorrect("ALTER TABLE [table_name] ADD [column_name] int PRIMARY KEY NOT NULL"); |
84 |
|
} |
85 |
|
|
|
|
| 0% |
Uncovered Elements: 8 (8) |
Complexity: 1 |
Complexity Density: 0.12 |
4
-
|
|
86 |
0
|
@SuppressWarnings("unchecked")... |
87 |
|
@Test |
88 |
|
public void generateSql_foreignKey() throws Exception { |
89 |
0
|
this.statementUnderTest = new AddColumnStatement(null, "table_name", "column_name", "int", null, new PrimaryKeyConstraint(), new ForeignKeyConstraint("fk_test_fk", "table_name(column_name)")); |
90 |
|
|
91 |
0
|
assertCorrect(new String[] {"alter table [table_name] add [column_name] int not null primary key", "alter table [table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [table_name]([column_name])"}, HsqlDatabase.class, MaxDBDatabase.class); |
92 |
0
|
assertCorrect(new String[] {"alter table [table_name] add [column_name] int primary key not null", "alter table [table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [table_name]([column_name])"}, SybaseASADatabase.class, SybaseDatabase.class); |
93 |
0
|
assertCorrect(new String[] {"alter table [dbo].[table_name] add [column_name] int not null primary key", "alter table [dbo].[table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [dbo].[table_name]([column_name])"}, MSSQLDatabase.class); |
94 |
0
|
assertCorrect(new String[] {"alter table table_name add column_name int not null primary key", "alter table [table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [table_name]([column_name])"}, PostgresDatabase.class); |
95 |
0
|
assertCorrect(new String[] {"alter table `table_name` add `column_name` int not null primary key", "alter table [table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [table_name]([column_name])"}, MySQLDatabase.class); |
96 |
0
|
assertCorrect(new String[] {"ALTER TABLE [table_name] ADD [column_name] int PRIMARY KEY NOT NULL", "alter table [table_name] add constraint foreign key ([column_name]) references [table_name]([column_name]) constraint [fk_test_fk]"}, InformixDatabase.class); |
97 |
0
|
assertCorrect(new String[] {"ALTER TABLE [table_name] ADD [column_name] int PRIMARY KEY NOT NULL", "alter table [table_name] add constraint [fk_test_fk] foreign key ([column_name]) references [table_name]([column_name])"}); |
98 |
|
} |
99 |
|
|
100 |
|
} |