@Test public void testConstructParameterizedInClause() { assertEquals("((?,?,?),(?,?,?))", QueryUtil.constructParameterizedInClause(3, 2)); assertEquals("((?))", QueryUtil.constructParameterizedInClause(1, 1)); }
public static String constructParameterizedInClause(int numWhereCols, int numBatches) { Preconditions.checkArgument(numWhereCols > 0); Preconditions.checkArgument(numBatches > 0); String batch = "(" + StringUtils.repeat("?", ",", numWhereCols) + ")"; return "(" + StringUtils.repeat(batch, ",", numBatches) + ")"; }
QueryUtil { public static String constructParameterizedInClause(int numWhereCols, int numBatches) { Preconditions.checkArgument(numWhereCols > 0); Preconditions.checkArgument(numBatches > 0); String batch = "(" + StringUtils.repeat("?", ",", numWhereCols) + ")"; return "(" + StringUtils.repeat(batch, ",", numBatches) + ")"; } }
QueryUtil { public static String constructParameterizedInClause(int numWhereCols, int numBatches) { Preconditions.checkArgument(numWhereCols > 0); Preconditions.checkArgument(numBatches > 0); String batch = "(" + StringUtils.repeat("?", ",", numWhereCols) + ")"; return "(" + StringUtils.repeat(batch, ",", numBatches) + ")"; } private  QueryUtil(); }
QueryUtil { public static String constructParameterizedInClause(int numWhereCols, int numBatches) { Preconditions.checkArgument(numWhereCols > 0); Preconditions.checkArgument(numBatches > 0); String batch = "(" + StringUtils.repeat("?", ",", numWhereCols) + ")"; return "(" + StringUtils.repeat(batch, ",", numBatches) + ")"; } private  QueryUtil(); static String toSQL(CompareOp op); static String constructUpsertStatement(String tableName, List<ColumnInfo> columnInfos); static String constructUpsertStatement(String tableName, List<String> columns, Hint hint); static String constructGenericUpsertStatement(String tableName, int numColumns); static String constructSelectStatement(String fullTableName, List<ColumnInfo> columnInfos,final String conditions); static String constructSelectStatement(String fullTableName, List<String> columns,
            final String whereClause, Hint hint, boolean escapeCols); static String constructParameterizedInClause(int numWhereCols, int numBatches); static String getUrl(String zkQuorum); static String getUrl(String zkQuorum, int clientPort); static String getUrl(String zkQuorum, String znodeParent); static String getUrl(String zkQuorum, int port, String znodeParent, String principal); static String getUrl(String zkQuorum, int port, String znodeParent); static String getUrl(String zkQuorum, Integer port, String znodeParent); static String getUrl(String zkQuorum, Integer port, String znodeParent, String principal); static String getExplainPlan(ResultSet rs); static String getExplainPlan(ResultIterator iterator); static Connection getConnectionOnServer(Configuration conf); static void setServerConnection(Properties props); static boolean isServerConnection(ReadOnlyProps props); static Connection getConnectionOnServer(Properties props, Configuration conf); static Connection getConnectionOnServerWithCustomUrl(Properties props, String principal); static Connection getConnection(Configuration conf); static String getConnectionUrl(Properties props, Configuration conf); static String getConnectionUrl(Properties props, Configuration conf, String principal); static String getViewStatement(String schemaName, String tableName, String where); static Integer getOffsetLimit(Integer limit, Integer offset); static Integer getRemainingOffset(Tuple offsetTuple); static String getViewPartitionClause(String partitionColumnName, long autoPartitionNum); static Connection getConnectionForQueryLog(Configuration config); static PreparedStatement getCatalogsStmt(PhoenixConnection connection); static PreparedStatement getSchemasStmt(
        PhoenixConnection connection, String catalog, String schemaPattern); static PreparedStatement getSuperTablesStmt(PhoenixConnection connection,
        String catalog, String schemaPattern, String tableNamePattern); static PreparedStatement getIndexInfoStmt(PhoenixConnection connection,
            String catalog, String schema, String table, boolean unique, boolean approximate); static PreparedStatement getTablesStmt(PhoenixConnection connection, String catalog, String schemaPattern,
        String tableNamePattern, String[] types); static void addTenantIdFilter(PhoenixConnection connection, StringBuilder buf, String tenantIdPattern,
                                         List<String> parameterValues); }
QueryUtil { public static String constructParameterizedInClause(int numWhereCols, int numBatches) { Preconditions.checkArgument(numWhereCols > 0); Preconditions.checkArgument(numBatches > 0); String batch = "(" + StringUtils.repeat("?", ",", numWhereCols) + ")"; return "(" + StringUtils.repeat(batch, ",", numBatches) + ")"; } private  QueryUtil(); static String toSQL(CompareOp op); static String constructUpsertStatement(String tableName, List<ColumnInfo> columnInfos); static String constructUpsertStatement(String tableName, List<String> columns, Hint hint); static String constructGenericUpsertStatement(String tableName, int numColumns); static String constructSelectStatement(String fullTableName, List<ColumnInfo> columnInfos,final String conditions); static String constructSelectStatement(String fullTableName, List<String> columns,
            final String whereClause, Hint hint, boolean escapeCols); static String constructParameterizedInClause(int numWhereCols, int numBatches); static String getUrl(String zkQuorum); static String getUrl(String zkQuorum, int clientPort); static String getUrl(String zkQuorum, String znodeParent); static String getUrl(String zkQuorum, int port, String znodeParent, String principal); static String getUrl(String zkQuorum, int port, String znodeParent); static String getUrl(String zkQuorum, Integer port, String znodeParent); static String getUrl(String zkQuorum, Integer port, String znodeParent, String principal); static String getExplainPlan(ResultSet rs); static String getExplainPlan(ResultIterator iterator); static Connection getConnectionOnServer(Configuration conf); static void setServerConnection(Properties props); static boolean isServerConnection(ReadOnlyProps props); static Connection getConnectionOnServer(Properties props, Configuration conf); static Connection getConnectionOnServerWithCustomUrl(Properties props, String principal); static Connection getConnection(Configuration conf); static String getConnectionUrl(Properties props, Configuration conf); static String getConnectionUrl(Properties props, Configuration conf, String principal); static String getViewStatement(String schemaName, String tableName, String where); static Integer getOffsetLimit(Integer limit, Integer offset); static Integer getRemainingOffset(Tuple offsetTuple); static String getViewPartitionClause(String partitionColumnName, long autoPartitionNum); static Connection getConnectionForQueryLog(Configuration config); static PreparedStatement getCatalogsStmt(PhoenixConnection connection); static PreparedStatement getSchemasStmt(
        PhoenixConnection connection, String catalog, String schemaPattern); static PreparedStatement getSuperTablesStmt(PhoenixConnection connection,
        String catalog, String schemaPattern, String tableNamePattern); static PreparedStatement getIndexInfoStmt(PhoenixConnection connection,
            String catalog, String schema, String table, boolean unique, boolean approximate); static PreparedStatement getTablesStmt(PhoenixConnection connection, String catalog, String schemaPattern,
        String tableNamePattern, String[] types); static void addTenantIdFilter(PhoenixConnection connection, StringBuilder buf, String tenantIdPattern,
                                         List<String> parameterValues); static final int COLUMN_FAMILY_POSITION; static final int COLUMN_NAME_POSITION; static final int DATA_TYPE_POSITION; static final int DATA_TYPE_NAME_POSITION; static final String IS_SERVER_CONNECTION; }