Package com.lingbobu.flashdb.common

Examples of com.lingbobu.flashdb.common.QueryResultSet

34
35
36
37
38
39
40
41
      if (i > 0) ts.append(',');
      ts.append('?');
    }
    ts.append(')');
   
    QueryResultSet qrs = flashDatabase.executeQuery(ts.toString(), params);
    return new JdbcResultSet(qrs);
  }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
 
  Object execute(String sql, Object[] params, int maxRows) {
    Object ret = flashDatabase.execute(sql, params, maxRows);
   
    if ((ret != null) && (ret instanceof QueryResultSet)) {
      QueryResultSet qrs = (QueryResultSet) ret;
      ResultSetNextPart rsContinue = null;
      if ((maxRows < 0) && qrs.isResultHasContinueData()) {
        rsContinue = new ResultSetNextPart(flashDatabase, sql, params, -maxRows);
      }
      return new JdbcResultSet((QueryResultSet)ret, rsContinue);
    }
    return ret;
View Full Code Here
59
60
61
62
63
64
65
66
67
68
    flashDatabase.executeCommand(sql);
  }
 
  ResultSet executeQuery(String sql, Object[] params, int maxRows) throws SQLException {
    if (maxRows == 0) {
      QueryResultSet qrs = flashDatabase.executeQuery(sql, params);
      return new JdbcResultSet(qrs);
    }
    return (ResultSet) execute(sql, params, maxRows);
  }
View Full Code Here
49
50
51
52
53
54
55
56
57
58
   
    this.joinFieldRelate = relateColumn.getName();
    this.isPrimaryKeyR = (isFirstColumnIsUnique && (relateColumn == this.columns[0]));
   
    if (loadData) {
      QueryResultSet qrsData = flashDatabase.executeQuery(dataSql, new Object[0]);
      this.key2rows = readKey2rows(qrsData, joinFieldRelate, isPrimaryKeyR);
    }
    else this.key2rows = null;
  }
View Full Code Here
72
73
74
75
76
77
78
79
    this.columns = base.columns;
    this.isPrimaryKeyR = base.isPrimaryKeyR;
    this.fieldMainIsArray = base.fieldMainIsArray;

    String dataSql = base.dataSqlIsComplex ? base.dataSql : (base.dataSql + " where "+ joinFieldRelate + " in ?");
    QueryResultSet qrs = flashDatabase.executeQuery(dataSql, new Object[]{partJoinKeys});
    this.key2rows = readKey2rows(qrs, joinFieldRelate, isPrimaryKeyR);
  }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
  }

  private FlashDatabase flashDatabase;
 
  public Object queryForObject(String sql) {
    QueryResultSet qrs = flashDatabase.executeQuery(sql, new Object[0]);
    if (qrs.getColumnCount() != 1)
      throw new RuntimeException("Result of queryForObject(...) must be only one column.");
    if (qrs.getRowCount() > 1)
      throw new RuntimeException("Result of queryForObject(...) must be only one row.");
    if (qrs.getRowCount() == 0)
      return null;
    else
      return qrs.fastGetValue(0, 0);
  }
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
    else
      return qrs.fastGetValue(0, 0);
  }
 
  public Set<Object> queryForSet(String sql) {
    QueryResultSet qrs = flashDatabase.executeQuery(sql, new Object[0]);
    if (qrs.getColumnCount() != 1)
      throw new RuntimeException("Result of queryForSet(...) must be only one column.");
    Set<Object> result = new HashSet<Object>();
    for (int i=0; i < qrs.getRowCount(); i++) {
      Object value = qrs.fastGetValue(i, 0);
      if (value == null) continue;
      result.add(value);
    }
    return result;
  }
View Full Code Here
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
    Object[] keyValues;
    if (mainIsTableName) {
      String mainSql = "select "+mainKeyColumnInfo.getName()+" from "+mainTableOrSql;
      if ((condition != null) && (! condition.isEmpty()))
        mainSql += " where " + condition;
      QueryResultSet qrs = flashDatabase.executeQuery(mainSql, conditionParams != null ? conditionParams : new Object[0]);
      keyValues = new Object[qrs.getRowCount()];
      for (int i=0; i < keyValues.length; i++) {
        keyValues[i] = qrs.getValue(i, 0);
      }
      Arrays.sort(keyValues);
    }
    else {
      QueryResultSet qrs = flashDatabase.executeQuery(mainTableOrSql, conditionParams != null ? conditionParams : new Object[0]);
      keyValues = new Object[qrs.getRowCount()];
      for (int i=0; i < keyValues.length; i++) {
        keyValues[i] = qrs.getRow(i);
      }
    }
   
    // 根据主键分段
    int partCount = (keyValues.length + partSize - 1) / partSize;
View Full Code Here
TOP

Related Classes of com.lingbobu.flashdb.common.QueryResultSet

  • com.lingbobu.flashdb.jdbc.JdbcConnection
  • com.lingbobu.flashdb.transfer.impl.ConverterJoinTable
  • com.lingbobu.flashdb.transfer.impl.InputLargeCombines
  • com.lingbobu.flashdb.transfer.sqlfunc.DbUtil
    • Copyright © 2018 www.massapicom. 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.