循環結果集取決於生成的列數

Question

我正在開發一個多線程項目，我需要隨機找到columns，我將在我的SELECT sql中使用該數據，然後我將執行該SELECT sql查詢。

尋找那些columns-

1. 我需要看到的ID是否有效範圍之間，如果在有效範圍內之間，然後周圍的結果集循環中使用這些列從columnsList並獲得後數據返回並存儲在一個變量中。
2. 否則，如果id不在有效範圍內，我需要檢查我沒有從結果集中取回任何數據。但不知何故，如果我得到的數據返回和標誌是真的停止程序，然後退出程序。否則，如果我得到的數據回來，但標誌是假的停止該程序，然後計數有多少這些發生。

下面是我的代碼 -

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, ","); 
} 

問題聲明 -

我不能夠理解我應該如何通過ResultSet，我將有不同列每次迭代我的SELECT sql取決於生成的內容。除此之外，我怎樣才能讓它在if循環中變得更清潔。

Answer 1

OK .. 你可以有隨機生成的列保存在一個字符串array..and然後同時通過迭代結果集您使用數組...如下： UPDATE
你不應該包括那些列在選擇statement..Instead您應該選擇使用*在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"); 
} 

UPDATE1
您需要在產品運行中寫你的關鍵代碼段（）被包裹在synchronized塊，以避免競爭條件如下：

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++; 
    } 
} 

我也更新瞭如果其他條件按我的問題的理解。