亡羊補牢,為時未晚!!!

          Posted on 2010-09-06 11:21 java小爬蟲 閱讀(1543) 評論(0)  編輯  收藏
              有這么一種場景,設計好的數據模型在有數據以后要修改數據模型。本文就是針對這個問題展開的。
              要增加,刪除一列,這根本不是問題,關鍵是要修改一列。這需要考慮到那些問題呢?
              在java里面有類型轉換,轉換分為兩種:自然轉換和強制轉換。自然轉換就是把子類型轉成父類型,強制轉換就是把父類型轉成子類型。在數據庫里面也一樣,當然還要包括長度的截短和加長。強制轉換和截短會造成數據的不準確和異常,本文不考慮這個情況。
              那么,如何改變數據表的列類型呢?通過SQL語句直接操作數據庫,當然能解決這個問題,可是,如何有很多張表都要修改呢?那不把人累死了!!!
           
              我就碰到了這么一個問題,加班加點的,寫成了一個JAVA小程序,來自動實現我的要求。

              需求:把數據庫中字段類型為blob和varchar2(4000)的數據表都修改為clob;

              問題解決思路:復制數據表結構和數據到一個臨時表,先刪除要修改的列,再創建同名不同類型的列,從原始表中查出這一列的數據,復制的臨時表中,刪除原始表,修改臨時表名為原始表名。

              處理過程日志截圖:


              代碼思路及重要代碼:
              1:獲取系統所有的用戶表:
                       String sql = " select table_name from user_tables " ;
              2:獲取表的主鍵(只考慮單主鍵) 
                       String sql = "  select column_name from user_cons_columns " +
                                  "  where constraint_name = (" +
                                        "  select constraint_name from user_constraints " +
                                            " where table_name = upper('"+tableName+"') " +
                                                "and constraint_type = 'P'" +
                                                    ")" ; 
              3:獲取表中列信息:列名,類型 和長度。
                       String sql = " select column_name,data_type,data_length from user_tab_columns  where table_name =  '"+ tableName+"'" ;   
              4:根據2和3,判斷要修改的列,組織(主鍵和要修改的列信息)數據。
                  代碼片段:

                  List<String[]> :裝有要修改表的表名,主鍵,列信息(列名,類型,長度);List中,第一條數據為表名,第二條數據為主鍵,其余為要修改的列信息,String[]為變長數組;
             
          String columnName="";
                  String dataType
          ="";
                  String dataLength
          ="";
                  List
          <String[]> result = new ArrayList<String[]>(3);
                  result.add(
          new String[]{tableName});
                  String primaryKeyName 
          = getPrimaryKey(tableName);
                  
          if(primaryKeyName.equals("")||primaryKeyName==nullreturn null ;
                  result.add(
          new String[]{primaryKeyName});
                      
          try {
                          String sql 
          = " select column_name,data_type,data_length from user_tab_columns  where table_name =  '"+ tableName+"'" ;    
                          ResultSet resultSet 
          = OracleDBUtil.executeQuery(sql);
                          
          while(resultSet.next()){
                              columnName
          =resultSet.getString(1);
                              dataType
          =resultSet.getString(2);
                              dataLength
          =resultSet.getString(3);
                              
          if(dataType.equals("BLOB")){
                                  result.add(
          new String[]{columnName,dataType});
                              }
          else if((dataType.equals("VARCHAR2")&&Integer.parseInt(dataLength) >= Constant.varchar2_size)||(dataType.equals("VARCHAR")&&Integer.parseInt(dataLength) >= Constant.varchar2_size)){
                                  result.add(
          new String[]{columnName,dataType,dataLength});
                              }
                          }
                          resultSet.close();
                      } 
          catch (SQLException e1) {
                          e1.printStackTrace();
                      }
                  
          return result;
              5:取出4返回的信息,組織數據,啟動修改流程;
          for (List<String[]> table : tables) {
                      
          //tableInfo = tableInfo+  "\t表名:\t" ;
                      tableInfo = "\t表名:\t" ;
                      tableInfo 
          = tableInfo+table.get(0)[0]+ "\t主鍵 :\t "+table.get(1)[0]+" \t字段 :\t ";
                      String[] columns 
          = new String[table.size()-2];
                      
          for (int i =2;i<table.size();i++) {
                          
          if(table.get(i)==nullbreak ;
                          tableInfo 
          = tableInfo+table.get(i)[0]+"  "+table.get(i)[1];
                          
          if(table.get(i).length == 3) tableInfo = tableInfo+ "("+table.get(i)[2]+")";
                          tableInfo 
          = tableInfo + "\t";
                          String[] columnInfo 
          = table.get(i) ;
                          columns[i
          -2]=columnInfo[0];
                      }
                      tableInfo 
          = tableInfo+"\n";
                      System.out.println(tableInfo);
                      
                      
                      BufferedReader in 
          = new BufferedReader(new InputStreamReader(System.in));
                      String str 
          = "";
                          System.out.println(
          "   是否修改,請輸入'Y'或者'N' ! ");
                          
          try {
                              str 
          = in.readLine();
                          } 
          catch (IOException e) {
                              e.printStackTrace();
                          }
                          
          if(str.equalsIgnoreCase("y")){
                              blobOrVarchar2Clob(table.get(
          0)[0],table.get(1)[0],columns);
                          }
                  }
                  
                  System.out.println(
          "數據表修改處理邏輯結束!!!");

              6:修改流程:使用了門面模式,實現了“復制數據表結構和數據到一個臨時表,先刪除要修改的列,再創建同名不同類型的列,從原始表中查出這一列的數據,復制的臨時表中,刪除原始表,修改臨時表名為原始表名。”構想。
              
          public static boolean blobOrVarchar2Clob(String srcTableName, String srcTableIdName, String columnNames) {
                  
          if (srcTableName == null || srcTableName.equals("")
                          
          || columnNames == null || columnNames.length == 0
                          
          || srcTableIdName == null || srcTableIdName.equals(""))
                      
          return false;
                  String printColumnNames 
          = "" ;
                  
          for (String columnName : columnNames) {
                      printColumnNames 
          += "  " +  columnName ;
                  }
                  System.out.println(
          "馬上就被修改  表名: "+srcTableName +  "   ,ID: " + srcTableIdName+"  字段:   "+printColumnNames);
                  Utils.createTempTable(srcTableName);
                  
          for (String columnName : columnNames) {
                      
          if(columnName==null||columnName.equals(""))continue ;
                      Utils.dropTempTableColumn(srcTableName, columnName);
                      Utils.addTempTableClobColumn(srcTableName, columnName);
                      Utils.copyDataOneColumn(srcTableName, columnName, srcTableIdName);
                  }
                  Utils.dropSrcTable(srcTableName
          +"_");
          //        Utils.dropSrcTable(srcTableName);
          //        Utils.modifyTempTableToSrcTable(srcTableName);
                  return true;
              }

              7:從原始表復制一列數據到臨時表:將數據寫入Map結構,再寫入臨時表。
                代碼片斷:
             
          HashMap<Integer, String> map = new HashMap<Integer, String>();
              
                      
          try {
                          
          while(resultSet.next()){
                              String content 
          = "";            
                                  
          int id = resultSet.getInt(srcTableIdName);
                                  
                                  
          int columnIndex = resultSet.findColumn(columnName);
                                   ResultSetMetaData resulSetMetaData 
          = resultSet.getMetaData();
                                   String columnTypeName 
          =resulSetMetaData.getColumnTypeName(columnIndex);
                                  
                                   
          if("VARCHAR2".equals(columnTypeName)||"VARCHAR".equals(columnTypeName)){
                                       content 
          = resultSet.getString(columnName);
                                   }
          else if("BLOB".equals(columnTypeName)){
                                          Blob blob 
          = resultSet.getBlob(columnName);
                                          
          if(blob==null)continue;
                                          content 
          = Utils.readBlobToString(blob);
                                   }
                                  map.put(id, content);
                          }
                          resultSet.close();
                      } 
          catch (SQLException e1) {
                          e1.printStackTrace();
                      }
                  
                  Set
          <Entry <Integer,String> > set = map.entrySet();
                  Iterator
          <Entry<Integer, String>> iterator =set.iterator();
                  
          while(iterator.hasNext()){
                      Entry
          <Integer, String> entry = iterator.next();
                  sql 
          = " update " + srcTableName + "" + " set "
                      
          + columnName + " = ? where " + srcTableName + "_."
                      
          + srcTableIdName + " = ? "  ;
                  PreparedStatement pstatement 
          =OracleDBUtil.getPreparedStatement(sql);
                  
          try {
                      pstatement.setString(
          1, entry.getValue());
                      pstatement.setInt(
          2, entry.getKey());
                      OracleDBUtil.executeUpdate(pstatement);
                      pstatement.close();




          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 台州市| 璧山县| 永丰县| 衡东县| 舞钢市| 宁阳县| 察雅县| 富阳市| 九江市| 电白县| 尖扎县| 中超| 白银市| 黑河市| 莆田市| 吉安市| 石城县| 中阳县| 沁阳市| 卢龙县| 米脂县| 唐河县| 乌拉特前旗| 邛崃市| 宿迁市| 略阳县| 台安县| 肇庆市| 临洮县| 浮梁县| 沅江市| 泾川县| 闸北区| 新密市| 巴南区| 达州市| 甘孜| 昌吉市| 苗栗市| 崇礼县| 天台县|