Package org.apache.hadoop.chukwa.util

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

97
98
99
100
101
102
103
104
105
106
107
    String query = "select * from ["+table+"];";
    Macro mp = new Macro(current,query);
    query = mp.toString();
    try {
      DatabaseWriter db = new DatabaseWriter(cluster);
      ResultSet rs = db.query(query);
      while(rs.next()) {
        int i = 1;
        String value = rs.getString(i);
      }
      db.close();
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
        DatabaseWriter db = new DatabaseWriter(cluster);
        for(String table : tables) {
          String query = "select * from ["+table+"];";
          Macro mp = new Macro(current,query);
          query = mp.toString();
          ResultSet rs = db.query(query);
          rs.last();
          int count = rs.getRow();
          assertTrue("Table should exist and return empty result.", count==0);
        }
        db.close();
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    String query = "select * from ["+table+"];";
    Macro mp = new Macro(dbSetup.current,query);
    query = mp.toString();
    try {
      DatabaseWriter db = new DatabaseWriter(dbSetup.cluster);
      ResultSet rs = db.query(query);
      while(rs.next()) {
        int i = 1;
        String value = rs.getString(i);
      }
      db.close();
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
            table = table + "_";
          }
          table = table + parts[i];
        }
        String query = "show create table " + table + "_template;";
        ResultSet rs = dbw.query(query);
        while (rs.next()) {
          log.debug("table schema: " + rs.getString(2));
          query = rs.getString(2);
          log.debug("template table name:" + table + "_template");
          log.debug("replacing with table name:" + table + "_" + partition
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
      String table = this.table+"_"+interval;
      // Find the most recent entry
      try {
          String query = "select * from "+table+" order by timestamp desc limit 1";
              log.debug("Query: "+query);
              rs = db.query(query);
              if(rs==null) {
                  throw new SQLException("Table undefined.");
              }
              ResultSetMetaData rmeta = rs.getMetaData();
              boolean empty=true;
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
                end = start + (interval*60000);
      } catch (SQLException ex) {
          try {
            String query = "select * from "+this.table+" order by timestamp limit 1";
                log.debug("Query: "+query);
                  rs = db.query(query);
                  if(rs.next()) {
                    ResultSetMetaData rmeta = rs.getMetaData();
                    for(int i=1;i<=rmeta.getColumnCount();i++) {
                        if(rmeta.getColumnName(i).toLowerCase().equals("timestamp")) {
                          start = rs.getTimestamp(i).getTime();
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    DatabaseWriter dbWriter = new DatabaseWriter(cluster);
    while (ki.hasNext()) {
      String table = dbNames.get(ki.next().toString());
      String query = "select * from " + table + "_template limit 1";
      try {
        ResultSet rs = dbWriter.query(query);
        ResultSetMetaData rmeta = rs.getMetaData();
        HashMap<String, Integer> tableSchema = new HashMap<String, Integer>();
        for (int i = 1; i <= rmeta.getColumnCount(); i++) {
          tableSchema.put(rmeta.getColumnName(i), rmeta.getColumnType(i));
        }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
              table = table + "_";
            }
            table = table + parts[i];
          }
          String query = "show create table " + table + "_template;";
          ResultSet rs = dbw.query(query);
          while (rs.next()) {
            log.debug("table schema: " + rs.getString(2));
            query = rs.getString(2);
            log.debug("template table name:" + table + "_template");
            log.debug("replacing with table name:" + table + "_" + partition
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
      // Find the most recent entry
      try {
        String query = "select * from " + sumTable
            + " order by timestamp desc limit 1";
        log.debug("Query: " + query);
        rs = db.query(query);
        if (rs == null) {
          throw new SQLException("Table is undefined.");
        }
        ResultSetMetaData rmeta = rs.getMetaData();
        boolean empty = true;
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
      } catch (SQLException ex) {
        try {
          String query = "select * from " + table
              + " order by timestamp limit 1";
          log.debug("Query: " + query);
          rs = db.query(query);
          if (rs.next()) {
            ResultSetMetaData rmeta = rs.getMetaData();
            for (int i = 1; i <= rmeta.getColumnCount(); i++) {
              if (rmeta.getColumnName(i).toLowerCase().equals("timestamp")) {
                start = rs.getTimestamp(i).getTime();
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.