本文整理了Java中org.apache.phoenix.util.QueryUtil.constructParameterizedInClause方法的一些代码示例，展示了QueryUtil.constructParameterizedInClause的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryUtil.constructParameterizedInClause方法的具体详情如下：
包路径：org.apache.phoenix.util.QueryUtil
类名称：QueryUtil
方法名：constructParameterizedInClause

QueryUtil.constructParameterizedInClause介绍

[英]Constructs parameterized filter for an IN clause e.g. passing in numWhereCols=2, numBatches=3 results in ((?,?),(?,?),(?,?))
[中]为IN子句构造参数化过滤器，例如传入numWhereCols=2，numBatches=3会导致（（？，？），(?,?),(?,?))

代码示例

代码示例来源：origin: apache/phoenix

/**
 * Get the parameterized query to return all the invalid rows from a scrutiny job
 */
static String constructMetadataParamQuery(List<String> metadataSelectCols) {
  String pkColsCsv = getPksCsv();
  String query =
      QueryUtil.constructSelectStatement(OUTPUT_METADATA_TABLE_NAME, metadataSelectCols,
        pkColsCsv, null, true);
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(3, 1);
  return query + inClause;
}

代码示例来源：origin: apache/phoenix

private static String getAllInvalidParamQuery(Connection conn,
    SourceTargetColumnNames columnNames) throws SQLException {
  String whereQuery = constructOutputTableQuery(conn, columnNames, getPksCsv());
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size(), 1);
  String paramQuery = whereQuery + inClause;
  return paramQuery;
}

代码示例来源：origin: apache/phoenix

private static String getHasTargetRowQuery(Connection conn, SourceTargetColumnNames columnNames,
    long scrutinyTimeMillis) throws SQLException {
  String whereQuery =
      constructOutputTableQuery(conn, columnNames,
        getPksCsv() + ", " + SchemaUtil.getEscapedFullColumnName("HAS_TARGET_ROW"));
  String inClause =
      " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size() + 1, 1);
  String paramQuery = whereQuery + inClause;
  paramQuery = bindPkCols(columnNames, scrutinyTimeMillis, paramQuery);
  return paramQuery;
}

代码示例来源：origin: apache/phoenix

@Test
public void testConstructParameterizedInClause() {
  assertEquals("((?,?,?),(?,?,?))", QueryUtil.constructParameterizedInClause(3, 2));
  assertEquals("((?))", QueryUtil.constructParameterizedInClause(1, 1));
}

代码示例来源：origin: apache/phoenix

QueryUtil.constructParameterizedInClause(numTargetPkCols,
      currentBatchValues.size());
String indexQuery = targetTableQuery + inClause;

代码示例来源：origin: org.apache.phoenix/phoenix-core

/**
 * Get the parameterized query to return all the invalid rows from a scrutiny job
 */
static String constructMetadataParamQuery(List<String> metadataSelectCols) {
  String pkColsCsv = getPksCsv();
  String query =
      QueryUtil.constructSelectStatement(OUTPUT_METADATA_TABLE_NAME, metadataSelectCols,
        pkColsCsv, null, true);
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(3, 1);
  return query + inClause;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

/**
 * Get the parameterized query to return all the invalid rows from a scrutiny job
 */
static String constructMetadataParamQuery(List<String> metadataSelectCols) {
  String pkColsCsv = getPksCsv();
  String query =
      QueryUtil.constructSelectStatement(OUTPUT_METADATA_TABLE_NAME, metadataSelectCols,
        pkColsCsv, null, true);
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(3, 1);
  return query + inClause;
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

private static String getAllInvalidParamQuery(Connection conn,
    SourceTargetColumnNames columnNames) throws SQLException {
  String whereQuery = constructOutputTableQuery(conn, columnNames, getPksCsv());
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size(), 1);
  String paramQuery = whereQuery + inClause;
  return paramQuery;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

private static String getAllInvalidParamQuery(Connection conn,
    SourceTargetColumnNames columnNames) throws SQLException {
  String whereQuery = constructOutputTableQuery(conn, columnNames, getPksCsv());
  String inClause = " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size(), 1);
  String paramQuery = whereQuery + inClause;
  return paramQuery;
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

private static String getHasTargetRowQuery(Connection conn, SourceTargetColumnNames columnNames,
    long scrutinyTimeMillis) throws SQLException {
  String whereQuery =
      constructOutputTableQuery(conn, columnNames,
        getPksCsv() + ", " + SchemaUtil.getEscapedFullColumnName("HAS_TARGET_ROW"));
  String inClause =
      " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size() + 1, 1);
  String paramQuery = whereQuery + inClause;
  paramQuery = bindPkCols(columnNames, scrutinyTimeMillis, paramQuery);
  return paramQuery;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

private static String getHasTargetRowQuery(Connection conn, SourceTargetColumnNames columnNames,
    long scrutinyTimeMillis) throws SQLException {
  String whereQuery =
      constructOutputTableQuery(conn, columnNames,
        getPksCsv() + ", " + SchemaUtil.getEscapedFullColumnName("HAS_TARGET_ROW"));
  String inClause =
      " IN " + QueryUtil.constructParameterizedInClause(getPkCols().size() + 1, 1);
  String paramQuery = whereQuery + inClause;
  paramQuery = bindPkCols(columnNames, scrutinyTimeMillis, paramQuery);
  return paramQuery;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

QueryUtil.constructParameterizedInClause(numTargetPkCols,
      currentBatchValues.size());
String indexQuery = targetTableQuery + inClause;

代码示例来源：origin: org.apache.phoenix/phoenix-core

QueryUtil.constructParameterizedInClause(numTargetPkCols,
      currentBatchValues.size());
String indexQuery = targetTableQuery + inClause;