使用Storm实现实时大数据分析！

insertQuery.append("thresholdTimeStamp").append(") values (");

for(Field fields : tupleInfo.getFieldList())

{

insertQuery.append("?,");

}

insertQuery.append("?)");

prepStatement = connection.prepareStatement(insertQuery.toString());

}

catch (SQLException e)

{

e.printStackTrace();

}