protected static final String [] DB_SQL_QUOTED_S = {"\"", "[", "`", "\"", "\"", "\""};
protected static final String [] DB_SQL_QUOTED_E = {"\"", "]", "`", "\"", "\"", "\""};
private static final String [] DROP_OPTION = {" CASCADE CONSTRAINT PURGE", "", "", "", "", ""};
- private static final String [] SQL_TERMINATOR = {";", lineSeparator + "GO", ";", ";", ";", ";"};
- private static final String [] SQL_PREFIX = {"@", ":r ", "", "", "", ""};
+// private static final String [] cp.SQL_TERMINATOR = {";", lineSeparator + "GO", ";", ";", ";", ";"};
+// private static final String [] cp.SQL_PREFIX = {"@", ":r ", "", "", "", ""};
private static final String [][] sql = {
{ //ORACLE
"select "
+ "order by "
+ " a.name",
"select "
- + " name as object_name, 'PROCEDURE' as object_type from sys.objects where type ='P'"
+ + " name as object_name, 'PROCEDURE' as object_type from sys.procedures"
+ " union select "
+ " name as object_name, 'FUNCTION' as object_type from sys.objects where type in('FN', 'FS', 'FT', 'IF', 'TF') "
+ " union select "
+ " name as object_name, 'TRIGGER' as object_type from sys.triggers "
- + " union select "
- + " name as object_name, 'TYPE' as object_type from sys.table_types "
+ " order by object_name,object_type ",
"select "
+ " name as sequence_name,"
};
private static String sql_proc[] = {
"select text from user_source where type = ? and name = ? order by line",
- "select c.definition "
- + "from sys.views a "
+ "select d.definition "
+ + "from "
+ + " (select a.name,'PROCEDURE' as type,c.definition "
+ + "from sys.procedures a "
+ "inner join sys.objects b "
- + "on b.object_id = a.object_id "
+ + "on b.object_id = a.object_id "
+ "inner join sys.sql_modules c "
+ "on c.object_id = b.object_id "
- + "where a.name = ?"
+ + "union select "
+ + " a.name,'FUNCTION' as type,c.definition "
+ + "from sys.objects a "
+ + "inner join sys.objects b "
+ + "on b.object_id = a.object_id "
+ + "inner join sys.sql_modules c "
+ + "on c.object_id = b.object_id and a.type in('FN', 'FS', 'FT', 'IF', 'TF') "
+ + "union select "
+ + "a.name,'TRIGGER' as type,c.definition "
+ + "from sys.triggers a "
+ + "inner join sys.objects b "
+ + "on b.object_id = a.object_id "
+ + "inner join sys.sql_modules c "
+ + "on c.object_id = b.object_id) d "
+ + "where d.type = ? and d.name = ?"
};
private String database = null;
sbTbCnts.append(" NULL");
}
if (!strSplit[0][0].equals(tableName)){
- pw[1].println(SQL_PREFIX[cp.dbType] + "TABLES/" + tableName + ".sql");
- pw[2].println("DROP TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ DROP_OPTION[cp.dbType] + SQL_TERMINATOR[cp.dbType]);
- pw[3].println("TRUNCATE TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_PREFIX[cp.dbType] + "TABLES/" + tableName + ".sql");
+ pw[2].println("DROP TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ DROP_OPTION[cp.dbType] + cp.SQL_TERMINATOR[cp.dbType]);
+ pw[3].println("TRUNCATE TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
sbTbCnts.append(lineSeparator);
- sbTbCnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ sbTbCnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbTbCnts.append(lineSeparator);
pw[0] = new PrintWriter(new BufferedWriter(new FileWriter(new File(subFolder + "/" + tableName + ".sql"))));
strSplit[1] = CmnUtils.split(sbTbCnts.toString(), lineSeparator);
} else {
sbTbCnts.append(" NULL");
}
- pw[1].println(SQL_PREFIX[cp.dbType] + "TABLES/" + tableName + ".sql");
- pw[2].println("DROP TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ DROP_OPTION[cp.dbType] + SQL_TERMINATOR[cp.dbType]);
- pw[3].println("TRUNCATE TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_PREFIX[cp.dbType] + "TABLES/" + tableName + ".sql");
+ pw[2].println("DROP TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ DROP_OPTION[cp.dbType] + cp.SQL_TERMINATOR[cp.dbType]);
+ pw[3].println("TRUNCATE TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tableName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
sbTbCnts.append(lineSeparator);
- sbTbCnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ sbTbCnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbTbCnts.append(lineSeparator);
pw[0] = new PrintWriter(new BufferedWriter(new FileWriter(new File(subFolder + "/" + tableName + ".sql"))));
strSplit[1] = CmnUtils.split(sbTbCnts.toString(), lineSeparator);
sbIxCnts.append(", " + DB_SQL_QUOTED_S[cp.dbType]+ colName + DB_SQL_QUOTED_E[cp.dbType]);
if (constraintType.equals("U"))sbIx2Cnts.append(", " + DB_SQL_QUOTED_S[cp.dbType]+ colName + DB_SQL_QUOTED_E[cp.dbType]);
}
- sbIxCnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ sbIxCnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbIxCnts.append(lineSeparator);
- if (constraintType.equals("U"))sbIx2Cnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ if (constraintType.equals("U"))sbIx2Cnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbIx2Cnts.append(lineSeparator);
sbIx3Cnts.append(lineSeparator);
//Index Changed Process
if (strSplit[0][3].equals("P")){
sbIxCnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " PRIMARY KEY(");
- sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
} else if (strSplit[0][3].equals("U")){
sbIxCnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " UNIQUE(");
sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP UNIQUE(");
} else if (strSplit[0][3].equals("")){
sbIxCnts.append("CREATE INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " ON " + strSplit[0][0] + "(");
}
- sbIx3Cnts.append("DROP INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ sbIx3Cnts.append("DROP INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
} else if (strSplit[0][1].equals(indexName)){
if (colPos.equals("1")){
sbIxCnts.append(DB_SQL_QUOTED_S[cp.dbType]+ colName + DB_SQL_QUOTED_E[cp.dbType]);
else {
if (strSplit[0][3].equals("P")){
sbIxCnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " PRIMARY KEY(");
- sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
} else if (strSplit[0][3].equals("U")){
sbIxCnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " UNIQUE(");
sbIx2Cnts.append("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ " DROP UNIQUE(");
} else if (strSplit[0][3].equals("")){
sbIxCnts.append("CREATE INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ " ON " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ "(");
}
- sbIx3Cnts.append("DROP INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ sbIx3Cnts.append("DROP INDEX " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][1] + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
}
for(int i=0;i<strSplit[0].length;i++)CmnUtils.debugPrint("'" + strSplit[0][i] + "'");
sbIxCnts.append(", " + DB_SQL_QUOTED_S[cp.dbType]+ colName + DB_SQL_QUOTED_E[cp.dbType]);
if (constraintType.equals("U"))sbIx2Cnts.append(", " + DB_SQL_QUOTED_S[cp.dbType]+ colName + DB_SQL_QUOTED_E[cp.dbType]);
}
- sbIxCnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ sbIxCnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbIxCnts.append(lineSeparator);
- if (constraintType.equals("U"))sbIx2Cnts.append(")" + SQL_TERMINATOR[cp.dbType]);
+ if (constraintType.equals("U"))sbIx2Cnts.append(")" + cp.SQL_TERMINATOR[cp.dbType]);
sbIx2Cnts.append(lineSeparator);
sbIx3Cnts.append(lineSeparator);
while((strLine=br[0].readLine()) != null){
strSplit[0] = CmnUtils.split(strLine, cp.delimiter);
CmnUtils.debugPrint("'" + strSplit[0][0] + "'");
- pw[1].println(SQL_PREFIX[cp.dbType] + "VIEWS/" + strSplit[0][0] + ".sql");
- pw[2].println("DROP VIEW " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_PREFIX[cp.dbType] + "VIEWS/" + strSplit[0][0] + ".sql");
+ pw[2].println("DROP VIEW " + DB_SQL_QUOTED_S[cp.dbType]+ strSplit[0][0] + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
if (strSplit[0].length>1)CmnUtils.debugPrint("'" + strSplit[0][1] + "'");
pw[0] = new PrintWriter(new BufferedWriter(new FileWriter(new File(subFolder + "/" + strSplit[0][0] + ".sql"))));
strContents = alData2.get(0).trim();
strSplit[1] = CmnUtils.split(strContents, lineSeparator);
for(int i=0;i<strSplit[1].length;i++)if(!strSplit[1][i].trim().equals(""))pw[0].println(strSplit[1][i].replaceAll("\"\"","\"").replaceAll(Pattern.quote(cp.user.toUpperCase() + "."),"").replaceAll(Pattern.quote(cp.user.toLowerCase() + "."),""));
- pw[0].println(SQL_TERMINATOR[cp.dbType]);
+ pw[0].println(cp.SQL_TERMINATOR[cp.dbType]);
if (!strSplit[0][1].trim().equals(""))pw[0].println(commentOnTable(cp, strSplit[0][0], strSplit[0][1], TYPE_VIEW));
for(int i=0;i<alData.size();i++){
while((strLine=br[0].readLine()) != null){
strSplit[0] = CmnUtils.split(strLine, cp.delimiter);
CmnUtils.debugPrint("'" + strSplit[0][0] + "'");
- pw[1].println(SQL_PREFIX[cp.dbType] + "PROCEDURES/" + strSplit[0][0] + ".sql");
- pw[2].println("DROP " + strSplit[0][1] + " " + strSplit[0][0] + SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_PREFIX[cp.dbType] + "PROCEDURES/" + strSplit[0][0] + ".sql");
+ pw[2].println("DROP " + strSplit[0][1] + " " + strSplit[0][0] + cp.SQL_TERMINATOR[cp.dbType]);
if (strSplit[0].length>1)CmnUtils.debugPrint("'" + strSplit[0][1] + "'");
pw[0] = new PrintWriter(new BufferedWriter(new FileWriter(new File(subFolder + "/" + strSplit[0][0] + ".sql"))));
- pw[0].println("/* " + strSplit[0][0] + " */");
- pw[0].print("CREATE OR REPLACE ");
+ if (cp.dbType == cp.DB_TYPE_ORACLE){
+ pw[0].println("/* " + strSplit[0][0] + " */");
+ pw[0].print("CREATE OR REPLACE ");
+ }
stmt = dao.prepareSql(sql_proc[cp.dbType]);
stmt.setString(1,strSplit[0][1]);
stmt.setString(2,strSplit[0][0]);
alData = dao.getArrayList();
for(int i=0;i<alData.size();i++){
strContents = alData.get(i);
- if(!strContents.equals(""))pw[0].println(strContents.replaceAll(Pattern.quote(cp.user.toUpperCase() + "."),"").replaceAll(Pattern.quote(cp.user.toLowerCase() + "."),""));
+ if(!strContents.equals(""))pw[0].println(strContents.replaceAll("\"\"","\"").replaceAll(Pattern.quote(cp.user.toUpperCase() + "."),"").replaceAll(Pattern.quote(cp.user.toLowerCase() + "."),""));
+ }
+
+ if (cp.dbType == cp.DB_TYPE_SQLSERVER){
+ pw[0].println(cp.SQL_TERMINATOR[cp.dbType]);
+ //pw[0].println("/");
}
- //pw[0].println("/");
pw[0].close();
pw[0] = null;
}
} else {
pw[1].print(" CYCLE");
}
- pw[1].println(SQL_TERMINATOR[cp.dbType]);
- pw[2].println("DROP SEQUENCE " + DB_SQL_QUOTED_S[cp.dbType]+ seqName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_TERMINATOR[cp.dbType]);
+ pw[2].println("DROP SEQUENCE " + DB_SQL_QUOTED_S[cp.dbType]+ seqName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
for(int i=0;i<strSplit[0].length;i++)CmnUtils.debugPrint("'" + strSplit[0][i] + "'");
}
for(int i=1;i<3;i++)pw[i].close();
} else {
pw[1].print(DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ "@" + DB_SQL_QUOTED_S[cp.dbType]+ dbLnk + DB_SQL_QUOTED_S[cp.dbType]);
}
- pw[1].println(SQL_TERMINATOR[cp.dbType]);
- pw[2].println("DROP SYNONYM " + DB_SQL_QUOTED_S[cp.dbType]+ synmName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_TERMINATOR[cp.dbType]);
+ pw[2].println("DROP SYNONYM " + DB_SQL_QUOTED_S[cp.dbType]+ synmName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
for(int i=0;i<strSplit[0].length;i++)CmnUtils.debugPrint("'" + strSplit[0][i] + "'");
}
for(int i=1;i<3;i++)pw[i].close();
while((strLine=br[0].readLine()) != null){
strSplit[0] = CmnUtils.split(strLine, cp.delimiter);
if(!fkName.equals(strSplit[0][1]) && !fkName.equals("")){
- pw[1].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ " FOREIGN KEY (" + DB_SQL_QUOTED_S[cp.dbType]+ fkCol + DB_SQL_QUOTED_E[cp.dbType]+ ") REFERENCES " + DB_SQL_QUOTED_S[cp.dbType]+ rtbName + DB_SQL_QUOTED_E[cp.dbType]+ " (" + DB_SQL_QUOTED_S[cp.dbType]+ rfkCol + DB_SQL_QUOTED_E[cp.dbType]+ ")" + SQL_TERMINATOR[cp.dbType]);
- pw[2].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ " FOREIGN KEY (" + DB_SQL_QUOTED_S[cp.dbType]+ fkCol + DB_SQL_QUOTED_E[cp.dbType]+ ") REFERENCES " + DB_SQL_QUOTED_S[cp.dbType]+ rtbName + DB_SQL_QUOTED_E[cp.dbType]+ " (" + DB_SQL_QUOTED_S[cp.dbType]+ rfkCol + DB_SQL_QUOTED_E[cp.dbType]+ ")" + cp.SQL_TERMINATOR[cp.dbType]);
+ pw[2].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
for(int i=0;i<strSplit[0].length;i++)CmnUtils.debugPrint("'" + strSplit[0][i] + "'");
tbName = strSplit[0][0];
fkName = strSplit[0][1];
}
}
- pw[1].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ " FOREIGN KEY (" + DB_SQL_QUOTED_S[cp.dbType]+ fkCol + DB_SQL_QUOTED_E[cp.dbType]+ ") REFERENCES " + DB_SQL_QUOTED_S[cp.dbType]+ rtbName + DB_SQL_QUOTED_E[cp.dbType]+ " (" + DB_SQL_QUOTED_S[cp.dbType]+ rfkCol + DB_SQL_QUOTED_E[cp.dbType]+ ")" + SQL_TERMINATOR[cp.dbType]);
- pw[2].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ SQL_TERMINATOR[cp.dbType]);
+ pw[1].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " ADD CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ " FOREIGN KEY (" + DB_SQL_QUOTED_S[cp.dbType]+ fkCol + DB_SQL_QUOTED_E[cp.dbType]+ ") REFERENCES " + DB_SQL_QUOTED_S[cp.dbType]+ rtbName + DB_SQL_QUOTED_E[cp.dbType]+ " (" + DB_SQL_QUOTED_S[cp.dbType]+ rfkCol + DB_SQL_QUOTED_E[cp.dbType]+ ")" + cp.SQL_TERMINATOR[cp.dbType]);
+ pw[2].println("ALTER TABLE " + DB_SQL_QUOTED_S[cp.dbType]+ tbName + DB_SQL_QUOTED_E[cp.dbType]+ " DROP CONSTRAINT " + DB_SQL_QUOTED_S[cp.dbType]+ fkName + DB_SQL_QUOTED_E[cp.dbType]+ cp.SQL_TERMINATOR[cp.dbType]);
for(int i=1;i<3;i++)pw[i].close();
for(int i=1;i<3;i++)pw[i]=null;
br[0].close();
pw[1].print(" BUFFER_POOL " + bufPool + ")");
pw[1].print(" TABLESPACE " + DB_SQL_QUOTED_S[cp.dbType]+ tblSpace + DB_SQL_QUOTED_E[cp.dbType]);
if(logging.equals("NO")){
- pw[1].println(" NOLOGGING" + SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(" NOLOGGING" + cp.SQL_TERMINATOR[cp.dbType]);
} else {
- pw[1].println(SQL_TERMINATOR[cp.dbType]);
+ pw[1].println(cp.SQL_TERMINATOR[cp.dbType]);
}
} else {
pw[1].println(strLine);
pw[2].print(" BUFFER_POOL " + bufPool + ")");
pw[2].print(" TABLESPACE " + DB_SQL_QUOTED_S[cp.dbType]+ tblSpace + DB_SQL_QUOTED_E[cp.dbType]);
if(logging.equals("NO")){
- pw[2].println(" NOLOGGING" + SQL_TERMINATOR[cp.dbType]);
+ pw[2].println(" NOLOGGING" + cp.SQL_TERMINATOR[cp.dbType]);
} else {
- pw[2].println(SQL_TERMINATOR[cp.dbType]);
+ pw[2].println(cp.SQL_TERMINATOR[cp.dbType]);
}
} else {
pw[2].println(strLine);
pw[3].print(" BUFFER_POOL " + bufPool + ")");
pw[3].print(" TABLESPACE " + DB_SQL_QUOTED_S[cp.dbType]+ tblSpace + DB_SQL_QUOTED_E[cp.dbType]);
if(logging.equals("NO")){
- pw[3].println(" NOLOGGING" + SQL_TERMINATOR[cp.dbType]);
+ pw[3].println(" NOLOGGING" + cp.SQL_TERMINATOR[cp.dbType]);
} else {
- pw[3].println(SQL_TERMINATOR[cp.dbType]);
+ pw[3].println(cp.SQL_TERMINATOR[cp.dbType]);
}
} else {
pw[3].println(strLine);
br[0] = new BufferedReader(new FileReader(tb));
pw[0] = new PrintWriter(new BufferedWriter(new FileWriter(oTb)));
while((strLine=br[0].readLine()) != null){
- if(strLine.equals(")" + SQL_TERMINATOR[cp.dbType])){
+ if(strLine.equals(")" + cp.SQL_TERMINATOR[cp.dbType])){
rowNo = CmnUtils.getArrayRowNo(alData, 12, 1, tbName);
if (rowNo != -1){
rowData = CmnUtils.getArrayRowData(alData, 12, rowNo);
pw[0].print(" BUFFER_POOL " + bufPool + ")");
pw[0].print(" TABLESPACE " + DB_SQL_QUOTED_S[cp.dbType]+ tblSpace + DB_SQL_QUOTED_E[cp.dbType]);
if(logging.equals("NO")){
- pw[0].println(" NOLOGGING" + SQL_TERMINATOR[cp.dbType]);
+ pw[0].println(" NOLOGGING" + cp.SQL_TERMINATOR[cp.dbType]);
} else {
- pw[0].println(SQL_TERMINATOR[cp.dbType]);
+ pw[0].println(cp.SQL_TERMINATOR[cp.dbType]);
}
} else {
- pw[0].println(")" + SQL_TERMINATOR[cp.dbType]);
+ pw[0].println(")" + cp.SQL_TERMINATOR[cp.dbType]);
}
} else {
pw[0].println(strLine);
for(int i=0;i<sql[cp.dbType].length;i++){
fl= new File(folder + "/" + FILE_NAME[i] + "_" + database + "." + cp.fileExtension);
CmnUtils.debugPrint(fl.toString());
- //fl.delete();
+ fl.delete();
}
// disconnect database
if(!_tableCmnt.equals("")){
switch (_cp.dbType) {
case DB_TYPE_ORACLE:
- retVal = "COMMENT ON TABLE " + DB_SQL_QUOTED_S[_cp.dbType]+ _tableName + DB_SQL_QUOTED_E[_cp.dbType]+ " IS '" + _tableCmnt.replaceAll("'","''") + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "COMMENT ON TABLE " + DB_SQL_QUOTED_S[_cp.dbType]+ _tableName + DB_SQL_QUOTED_E[_cp.dbType]+ " IS '" + _tableCmnt.replaceAll("'","''") + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
break;
case DB_TYPE_SQLSERVER:
if(_type == TYPE_TABLE){
- retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _tableCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'table',@level1name=N'" + _tableName + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _tableCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'table',@level1name=N'" + _tableName + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
} else if(_type == TYPE_VIEW){
- retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _tableCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'view',@level1name=N'" + _tableName + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _tableCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'view',@level1name=N'" + _tableName + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
}
break;
default :
if(!_colCmnt.equals("")){
switch (_cp.dbType) {
case DB_TYPE_ORACLE:
- retVal = "COMMENT ON COLUMN " + DB_SQL_QUOTED_S[_cp.dbType]+ _tableName + DB_SQL_QUOTED_E[_cp.dbType]+ "." + DB_SQL_QUOTED_S[_cp.dbType]+ _colName + DB_SQL_QUOTED_E[_cp.dbType]+ " IS '" + _colCmnt.replaceAll("'","''") + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "COMMENT ON COLUMN " + DB_SQL_QUOTED_S[_cp.dbType]+ _tableName + DB_SQL_QUOTED_E[_cp.dbType]+ "." + DB_SQL_QUOTED_S[_cp.dbType]+ _colName + DB_SQL_QUOTED_E[_cp.dbType]+ " IS '" + _colCmnt.replaceAll("'","''") + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
break;
case DB_TYPE_SQLSERVER:
if(_type == TYPE_TABLE){
- retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _colCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'table',@level1name=N'" + _tableName + "',@level2type=N'column',@level2name=N'" + _colName + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _colCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'table',@level1name=N'" + _tableName + "',@level2type=N'column',@level2name=N'" + _colName + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
} else if(_type == TYPE_VIEW){
- retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _colCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'view',@level1name=N'" + _tableName + "',@level2type=N'column',@level2name=N'" + _colName + "'" + SQL_TERMINATOR[_cp.dbType];
+ retVal = "exec sys.sp_addextendedproperty @name=N'MS_Description',@value=N'" + _colCmnt.replaceAll("'","''") + "',@level0type=N'schema',@level0name=N'dbo',@level1type=N'view',@level1name=N'" + _tableName + "',@level2type=N'column',@level2name=N'" + _colName + "'" + _cp.SQL_TERMINATOR[_cp.dbType];
}
break;
default :