com/rapide_act/RapideMetaLoader.java

   1 package com.rapide_act;
   2
   3 import java.io.BufferedInputStream;
   4 import java.io.FileInputStream;
   5 import java.io.IOException;
   6 import java.io.InputStream;
   7 import java.io.InputStreamReader;
   8 import java.io.File;
   9 import java.io.FileReader;
  10 import java.io.FileWriter;
  11 import java.io.BufferedWriter;
  12 import java.io.BufferedReader;
  13 import java.io.PrintWriter;
  14 import java.io.PrintWriter;
  15 import java.util.Date;
  16 import java.util.ArrayList;
  17 import java.util.Iterator;
  18 import java.util.Properties;
  19 import java.sql.Connection;
  20 import java.sql.DriverManager;
  21 import java.sql.ResultSet;
  22 import java.sql.ResultSetMetaData;
  23 import java.sql.SQLException;
  24 import java.sql.PreparedStatement;
  25 import java.sql.Timestamp;
  26 import java.sql.Blob;
  27 import java.sql.Clob;
  28
  29 public class RapideMetaLoader{
  30
  31         private String database = null;
  32
  33         public static void main(String args[]){
  34                 try {
  35                         if (args.length > 0){
  36                                 RapideMetaLoader RapideMetaLoader = new RapideMetaLoader(args[0]);
  37                                 RapideMetaLoader.metaLoad();
  38                         } else {
  39                                 RapideMetaLoader RapideMetaLoader = new RapideMetaLoader(null);
  40                                 RapideMetaLoader.metaLoad();
  41                         }
  42                 } catch (Exception e) {
  43                         e.printStackTrace();
  44                 }
  45         }
  46
  47         RapideMetaLoader(String _database) {
  48                 super();
  49                 database = _database;
  50         }
  51
  52
  53         private void metaLoad(){
  54                 Connection conn = null;
  55                 PreparedStatement stmt = null;
  56                 BufferedReader br = null;
  57                 File folder = null;
  58                 File subFolder = null;
  59                 String strLine = null;
  60                 String strMltLine = null;
  61                 String tbName   = null;
  62                 String viewName         = null;
  63                 String procName         = null;
  64                 String [] flName = null;
  65                 File [] inFiles = null;
  66                 int tb_count = 0;
  67                 String [] sqlLine = null;
  68
  69                 CmnProps cp = null;
  70                 CmnAccessObjects dao = null;
  71
  72                 try {
  73                         cp = new CmnProps();
  74                         cp.setProperty(database);
  75
  76                         if (cp.dbType != cp.DB_TYPE_ORACLE){
  77                                 throw new Exception("\83f\81[\83^\83x\81[\83X\82ª\91Î\8fÛ\8aO\82Å\82·\81B[" + cp.DB_TYPE_NAME[cp.dbType] + "]");
  78                         }
  79                         if(cp.inFolder != null){
  80                                 folder = new File(cp.inFolder);
  81                         } else {
  82                                 if (database != null){
  83                                         folder = new File(cp.DEFAULT_IN_FOLDER + "/DDL_" + database.toUpperCase());
  84                                 } else {
  85                                         folder = new File(cp.DEFAULT_IN_FOLDER + "/DDL_" + cp.DB_TYPE_NAME[cp.dbType].toUpperCase());
  86                                 }
  87                         }
  88                         CmnUtils.infoPrint("-->\93ü\97Í\8c³\83t\83H\83\8b\83_='" + folder + "'");
  89                         CmnUtils.infoPrint("\83\81\83^\83f\81[\83^\83\8d\81[\83h\82ð\8aJ\8en\82µ\82Ü\82µ\82½\81B");
  90
  91                         // Connect
  92                         dao = new CmnAccessObjects(cp);
  93                         conn = dao.connect();
  94
  95                         if(cp.isDrop){
  96                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_TABLE], cp, true, false);
  97                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_VIEW], cp, true, false);
  98                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_PROCEDURE], cp, true, false);
  99                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_SYNONYM], cp, true, false);
 100                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_SEQUENCE], cp, true, false);
 101                                 executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.DROP_FK], cp, true, false);
 102                         }
 103                         subFolder = new File(folder + "/TABLES");
 104                         inFiles = subFolder.listFiles();
 105                         tb_count = 0;
 106                         if(inFiles != null) {
 107                                 for(int k=0;k<inFiles.length;k++){
 108                                         flName = CmnUtils.splitDot(inFiles[k].getName());
 109                                         tbName = flName[0];
 110                                         executeSqlFile(dao, stmt, subFolder + "/" + inFiles[k].getName(), cp, false, false);
 111                                 }
 112                         }
 113                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_PKEY], cp, false, false);
 114                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_UKEY], cp, false, false);
 115                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_INDEX], cp, false, false);
 116                         subFolder = new File(folder + "/VIEWS");
 117                         inFiles = subFolder.listFiles();
 118                         int view_count = 0;
 119                         if(inFiles != null) {
 120                                 for(int k=0;k<inFiles.length;k++){
 121                                         flName = CmnUtils.splitDot(inFiles[k].getName());
 122                                         viewName = flName[0];
 123                                         executeSqlFile(dao, stmt, subFolder + "/" + inFiles[k].getName(), cp, false, false);
 124                                 }
 125                         }
 126                         subFolder = new File(folder + "/PROCEDURES");
 127                         inFiles = subFolder.listFiles();
 128                         int proc_count = 0;
 129                         if(inFiles != null) {
 130                                 for(int k=0;k<inFiles.length;k++){
 131                                         flName = CmnUtils.splitDot(inFiles[k].getName());
 132                                         procName = flName[0];
 133                                         executeSqlFile(dao, stmt, subFolder + "/" + inFiles[k].getName(), cp, false, true);
 134                                 }
 135                         }
 136                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_SYNONYM], cp, false, false);
 137                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_SEQUENCE], cp, false, false);
 138                         executeSqlFile(dao, stmt, folder + "/" + cp.SQL_FILE_NAME[cp.CREATE_FK], cp, false, false);
 139
 140                         CmnUtils.infoPrint("\83\81\83^\83f\81[\83^\83\8d\81[\83h\82ð\8fI\97¹\82µ\82Ü\82µ\82½\81B");
 141
 142                 } catch(SQLException se) {
 143                         try{
 144                                 CmnUtils.errorPrint(se.toString());
 145                                 se.printStackTrace();
 146                                 se = se.getNextException();
 147                                 if(se != null) {
 148                                         System.out.println(se.getMessage());
 149                                 }
 150                                 dao.rollback();
 151                         } catch (Exception see) {}
 152                 } catch (Exception e) {
 153                         try{
 154                                 CmnUtils.errorPrint(e.toString());
 155                                 e.printStackTrace();
 156                                 dao.rollback();
 157                         } catch (Exception ee) {}
 158                 } finally{
 159                         try{
 160                                 dao.disconnect();
 161                                 if(stmt != null){
 162                                         stmt.close();
 163                                         stmt=null;
 164                                 }
 165                                 if(br!=null){
 166                                         br.close();
 167                                         br=null;
 168                                 }
 169                         } catch (Exception e) {}
 170                 }
 171         }
 172
 173         private void executeSqlFile(CmnAccessObjects _dao, PreparedStatement _stmt, String _infile, CmnProps _cp, boolean _isResume, boolean _isReplace) throws Exception{
 174                 BufferedReader br = null;
 175                 String strLine = null;
 176                 String strMltLine = "";
 177                 String [] sqlLine = null;
 178
 179                 File infile = new File(_infile);
 180                 if (infile.exists()){
 181                         br = new BufferedReader(new InputStreamReader(new FileInputStream(_infile), _cp.fileEncoding));
 182                         while((strLine=br.readLine()) != null){
 183                                 strMltLine += _cp.inColLineSeparator + strLine;
 184                         }
 185                         if(_isReplace){
 186                                 if(!strMltLine.equals("")){
 187                                         try {
 188                                                 _stmt = _dao.prepareSql(strMltLine.replaceAll("\r",""));
 189                                                 _stmt.executeUpdate();
 190                                                 if(_stmt != null){
 191                                                         _stmt.close();
 192                                                         _stmt=null;
 193                                                 }
 194                                         } catch (Exception e) {
 195                                                 if(!_isResume){
 196                                                         throw e;
 197                                                 }
 198                                         }
 199                                 }
 200                         } else {
 201                                 sqlLine = CmnUtils.split(strMltLine, ";");
 202                                 for(int l = 0;l<sqlLine.length;l++){
 203                                         if(!sqlLine[l].equals("")){
 204                                                 try {
 205                                                         _stmt = _dao.prepareSql(sqlLine[l].replaceAll("\r",""));
 206                                                         _stmt.executeUpdate();
 207                                                         if(_stmt != null){
 208                                                                 _stmt.close();
 209                                                                 _stmt=null;
 210                                                         }
 211                                                 } catch (Exception e) {
 212                                                         if(!_isResume){
 213                                                                 throw e;
 214                                                         }
 215                                                 }
 216                                         }
 217                                 }
 218                         }
 219                 }
 220         }
 221
 222 }
 223