|
|
@@ -3,6 +3,7 @@ package com.izouma.codegenerator;
|
|
|
import com.izouma.awesomeadmin.model.GenCode;
|
|
|
import com.izouma.awesomeadmin.model.TableField;
|
|
|
import com.izouma.awesomeadmin.util.PropertiesFileLoader;
|
|
|
+import org.apache.commons.lang.StringUtils;
|
|
|
|
|
|
import java.sql.Connection;
|
|
|
import java.sql.DriverManager;
|
|
|
@@ -45,20 +46,44 @@ public class TableGenerator {
|
|
|
public static void GenTable(GenCode model) throws Exception {
|
|
|
Connection conn = null;
|
|
|
try {
|
|
|
- Class.forName("com.mysql.jdbc.Driver");
|
|
|
- System.out.println("成功加载MySQL驱动!");
|
|
|
|
|
|
- PropertiesFileLoader propertiesFileLoader = PropertiesFileLoader.getInstance();
|
|
|
- propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.url");
|
|
|
+ if ("Mysql".equals(model.getDataBaseType())) {
|
|
|
+ Class.forName("com.mysql.jdbc.Driver");
|
|
|
+ System.out.println("成功加载MySQL驱动!");
|
|
|
+
|
|
|
+ PropertiesFileLoader propertiesFileLoader = PropertiesFileLoader.getInstance();
|
|
|
+ propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.url");
|
|
|
+
|
|
|
+ String url = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.url");
|
|
|
+ String user = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.username");
|
|
|
+ String password = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.password");
|
|
|
+ conn = DriverManager.getConnection(url, user, password);
|
|
|
+
|
|
|
+ System.out.println("成功连接到数据库!");
|
|
|
+ } else if ("SqlServer".equals(model.getDataBaseType())) {
|
|
|
+ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
|
|
|
+ System.out.println("成功加载SQLServer驱动!");
|
|
|
+
|
|
|
+ PropertiesFileLoader propertiesFileLoader = PropertiesFileLoader.getInstance();
|
|
|
+ propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.url");
|
|
|
+
|
|
|
+ String url = propertiesFileLoader.getProperties("properties/jdbc.properties", "sqlserver.url");
|
|
|
+ String user = propertiesFileLoader.getProperties("properties/jdbc.properties", "sqlserver.user");
|
|
|
+ String password = propertiesFileLoader.getProperties("properties/jdbc.properties", "sqlserver.password");
|
|
|
+ conn = DriverManager.getConnection(url, user, password);
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
- String url = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.url");
|
|
|
- String user = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.username");
|
|
|
- String password = propertiesFileLoader.getProperties("properties/jdbc.properties", "jdbc.password");
|
|
|
- conn = DriverManager.getConnection(url, user, password);
|
|
|
Statement stmt = conn.createStatement();
|
|
|
- System.out.println("成功连接到数据库!");
|
|
|
|
|
|
- String sql = "DROP TABLE IF EXISTS "+ model.getTableName() + "; create table " + model.getTableName() + "(";
|
|
|
+ String sql = "DROP TABLE IF EXISTS " + model.getTableName() + "; create table " + model.getTableName() + "(";
|
|
|
+
|
|
|
+ if ("SqlServer".equals(model.getDataBaseType())) {
|
|
|
+ sql = "IF EXISTS (SELECT * FROM sys.objects where name = '" + model.getTableName() + "')DROP TABLE " + model.getTableName()
|
|
|
+ + "; create table " + model.getTableName() + "(";
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
for (TableField tableField : model.getFields()) {
|
|
|
if (tableField.getLength() == null) {
|
|
|
switch (tableField.getJdbcType()) {
|
|
|
@@ -88,7 +113,22 @@ public class TableGenerator {
|
|
|
tableField.setLength(0);
|
|
|
}
|
|
|
|
|
|
- sql += " " + tableField.getName() + " " + tableField.getJdbcType() + "(" + tableField.getLength() + ")";
|
|
|
+
|
|
|
+ if ("Mysql".equals(model.getDataBaseType())) {
|
|
|
+
|
|
|
+ sql += " " + tableField.getName() + " " + tableField.getJdbcType() + "(" + tableField.getLength() + ")";
|
|
|
+
|
|
|
+ } else if ("SqlServer".equals(model.getDataBaseType())) {
|
|
|
+ if ("int".equals(tableField.getJdbcType())) {
|
|
|
+
|
|
|
+ sql += " " + tableField.getName() + " " + tableField.getJdbcType();
|
|
|
+ } else {
|
|
|
+ sql += " " + tableField.getName() + " " + tableField.getJdbcType() + "(" + tableField.getLength() + ")";
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
if (tableField.getNotNull()) {
|
|
|
sql += " not null ";
|
|
|
}
|
|
|
@@ -96,12 +136,26 @@ public class TableGenerator {
|
|
|
sql += " primary key ";
|
|
|
}
|
|
|
if (tableField.getAutoIncrease()) {
|
|
|
- sql += " auto_increment ";
|
|
|
+ if ("Mysql".equals(model.getDataBaseType())) {
|
|
|
+
|
|
|
+ sql += " auto_increment ";
|
|
|
+
|
|
|
+ } else if ("SqlServer".equals(model.getDataBaseType())) {
|
|
|
+ sql += " identity(1,1) ";
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
if (tableField.getDefaultValue() != null) {
|
|
|
sql += " default " + "'" + tableField.getDefaultValue() + "'";
|
|
|
}
|
|
|
- sql += " comment " + "'" + tableField.getRemark() + "',";
|
|
|
+
|
|
|
+ if (StringUtils.isNotEmpty(tableField.getRemark())) {
|
|
|
+ if ("Mysql".equals(model.getDataBaseType())) {
|
|
|
+ sql += " comment " + "'" + tableField.getRemark() + "'";
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ sql += ",";
|
|
|
}
|
|
|
String str = sql.substring(0, sql.lastIndexOf(","));
|
|
|
String sql1 = str + " )";
|