根据生成的列循环遍历结果集

Question

我正在处理一个多线程项目，我需要在其中随机找到将在我的SELECT sql 中使用的columns，然后我将执行该 SELECT sql 查询。

找到那些列后-

1. 我需要查看 id 是否在有效范围之间，如果它在有效范围之间，则使用 columnsList 中的那些列循环结果集并取回数据并存储在变量中。
2. 否则，如果 id 不在有效范围内，我需要检查我没有从结果集中取回任何数据。但不知何故，如果我要取回数据并且标志为真以停止程序，然后退出程序。否则，如果我正在取回数据但标志为 false 以停止程序，那么请计算发生了多少次。

下面是我的代码-

private volatile int count;

@Override
public void run() {

.....

final String columnsList = getColumns(table.getColumns());
....
rs = preparedStatement.executeQuery();
....
if (Read.endValidRange < id && id < Read.startValidRange) {

    while (rs.next()) {
        for(String column: columnsList.split(",")) {
            System.out.println(column + ": " + rs.getString(column));
        }
    }
} else {
    if(rs.next() && Read.flagTerminate) {
        System.exit(1);
    } else {
        count++;
    }
}

....

}

/**
 * A simple method to get the column names in the order in which it was
 * inserted
 * 
 * @param columns
 * @return
 */
private String getColumns(final List<String> columns) {
    List<String> copy = new ArrayList<String>(columns);
    Collections.shuffle(copy);

    int rNumber = random.nextInt(columns.size());

    List<String> subList = copy.subList(0, rNumber);
    Collections.sort(subList, new Comparator<String>() {

        @Override
        public int compare(String o1, String o2) {
            return columns.indexOf(o1) < columns.indexOf(o2) ? -1 : 1;
        }
    });
    return StringUtils.join(subList, ",");
}

问题陈述-

我无法理解我应该如何遍历结果集，因为每次我的 SELECT sql 中都会有不同的列，具体取决于生成的内容。除此之外，我怎样才能使它在 if else 循环中更干净。

Answer 1

好的.. 您可以将随机生成的列保存在字符串数组中......然后在通过结果集迭代时使用该数组......如下所示： 更新
您不应该在 select 语句中包含这些列。相反，您应该使用 *...选择 select 语句中的所有列...然后在 rs.next() 循环中获取该列的值...

rs = con.executeQuery("Select * from tablename");
while(rs.next())
{
   for (String col : columnsList )
   {
     System.out.print(rs.get(col));
   }
   System.out.print("\n");
}

更新1
您需要将您在 run() 中编写的关键代码部分包装在同步块中，以避免出现竞争条件，如下所示：

private volatile int count;

@Override
public void run() {

.....
while (!Read.flagTerminate)
{
    synchronized(this)
    {
        if (!Read.flagTerminate)
        {
            String columnsList = getColumns(table.getColumns());
            ....
            rs = preparedStatement.executeQuery();
            ....
            if (Read.endValidRange < id && id < Read.startValidRange) 
            {
                while (rs.next()) 
                {
                    for(String column: columnsList.split(",")) 
                    {
                        System.out.println(column + ": " + rs.getString(column));
                    }
                }
            } 
            else 
            {
                while (rs.next())
                {
                    count++;
                }
            }
        }

    }
}
System.exit(0);//it implies that flag = true;

....

}

/**
 * A simple method to get the column names in the order in which it was
 * inserted
 * 
 * @param columns
 * @return
 */
private String getColumns(final List<String> columns) {
    List<String> copy = new ArrayList<String>(columns);
    Collections.shuffle(copy);

    int rNumber = random.nextInt(columns.size());

    List<String> subList = copy.subList(0, rNumber);
    Collections.sort(subList, new Comparator<String>() {

        @Override
        public int compare(String o1, String o2) {
            return columns.indexOf(o1) < columns.indexOf(o2) ? -1 : 1;
        }
    });
    return StringUtils.join(subList, ",");
}

Answer 2

这个呢：

if (Read.endValidRange < id && id < Read.startValidRange) {
    while (rs.next()) {
        for (String column : columnsList.split(",")) {
            System.out.println(column + ": " + rs.getString(column));
        }
    }
} else if (rs.next()) {
    if (Read.flagTerminate) {
        System.exit(1);
    } else {
        count++;
    }
}

我还根据我对问题的理解更新了 if-else 条件。