Package org.apache.hadoop.chukwa.util

Examples of org.apache.hadoop.chukwa.util.DatabaseWriter.execute()

80
81
82
83
84
85
86
87
88
89
90
      while(rs.next()) {
        String table = rs.getString(1);
        list.add(table);
      }
      for(String table : list) {
        db.execute("drop table "+table);
      }
    } catch(Throwable ex) {
    } finally {
      if(db!=null) {
        db.close();
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
              table = table + parts[i];
            }
            partition = partition - 3;
            String dropPartition = "drop table if exists " + table + "_"
                + partition + "_" + parts[parts.length - 1];
            dbw.execute(dropPartition);
            partition--;
            if(partition>=0) {
              dropPartition = "drop table if exists " + table + "_" + partition
                  + "_" + parts[parts.length - 1];
              dbw.execute(dropPartition);
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
            dbw.execute(dropPartition);
            partition--;
            if(partition>=0) {
              dropPartition = "drop table if exists " + table + "_" + partition
                  + "_" + parts[parts.length - 1];
              dbw.execute(dropPartition);
            }
          } catch (NumberFormatException e) {
            log
                .error("Error in parsing table partition number, skipping table:"
                    + tableList[0]);
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
          log.debug("creating table: " + query);
          String createPartition = query.replaceFirst(table + "_template",
              table + "_" + partition + "_" + parts[parts.length - 1]);
          createPartition = createPartition.replaceFirst("TABLE",
              "TABLE IF NOT EXISTS");
          dbw.execute(createPartition);
          partition++;
          createPartition = query.replaceFirst(table + "_template", table
              + "_" + partition + "_" + parts[parts.length - 1]);
          createPartition = createPartition.replaceFirst("TABLE",
              "TABLE IF NOT EXISTS");
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
          partition++;
          createPartition = query.replaceFirst(table + "_template", table
              + "_" + partition + "_" + parts[parts.length - 1]);
          createPartition = createPartition.replaceFirst("TABLE",
              "TABLE IF NOT EXISTS");
          dbw.execute(createPartition);
          partition++;
          createPartition = query.replaceFirst(table + "_template", table
              + "_" + partition + "_" + parts[parts.length - 1]);
          createPartition = createPartition.replaceFirst("TABLE",
              "TABLE IF NOT EXISTS");
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
          partition++;
          createPartition = query.replaceFirst(table + "_template", table
              + "_" + partition + "_" + parts[parts.length - 1]);
          createPartition = createPartition.replaceFirst("TABLE",
              "TABLE IF NOT EXISTS");
          dbw.execute(createPartition);
        }
      } catch (NumberFormatException e) {
        log.error("Error in parsing table partition number, skipping table:"
            + tableList[0]);
      } catch (ArrayIndexOutOfBoundsException e) {
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
          if(emptyPrimeKey) {
            groupBy = "group by "+dateclause;
          }
        String query = "insert ignore into "+this.table+"_"+interval+" (select "+fields+" from "+table+" where "+dateclause+groupBy+")";
        log.debug(query);
                db.execute(query);
                db.close();
            if(previousStart == start) {
              start = start + (interval*60000);
              end = start + (interval*60000);
                previousStart = start;
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
            log.debug("creating table: " + query);
            String createPartition = query.replaceFirst(table + "_template",
                table + "_" + partition + "_" + parts[parts.length - 1]);
            createPartition = createPartition.replaceFirst("TABLE",
                "TABLE IF NOT EXISTS");
            dbw.execute(createPartition);
            partition++;
            createPartition = query.replaceFirst(table + "_template", table
                + "_" + partition + "_" + parts[parts.length - 1]);
            createPartition = createPartition.replaceFirst("TABLE",
                "TABLE IF NOT EXISTS");
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
            partition++;
            createPartition = query.replaceFirst(table + "_template", table
                + "_" + partition + "_" + parts[parts.length - 1]);
            createPartition = createPartition.replaceFirst("TABLE",
                "TABLE IF NOT EXISTS");
            dbw.execute(createPartition);
            partition++;
            createPartition = query.replaceFirst(table + "_template", table
                + "_" + partition + "_" + parts[parts.length - 1]);
            createPartition = createPartition.replaceFirst("TABLE",
                "TABLE IF NOT EXISTS");
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
            partition++;
            createPartition = query.replaceFirst(table + "_template", table
                + "_" + partition + "_" + parts[parts.length - 1]);
            createPartition = createPartition.replaceFirst("TABLE",
                "TABLE IF NOT EXISTS");
            dbw.execute(createPartition);
          }
        } catch (NumberFormatException e) {
          log.error("Error in parsing table partition number, skipping table:"
              + tableList[0]);
        } catch (ArrayIndexOutOfBoundsException e) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.