Commit 125f225d authored by 赵建伟's avatar 赵建伟

update codes

parent a48df6b8
...@@ -215,7 +215,7 @@ ...@@ -215,7 +215,7 @@
<workItem from="1584945647680" duration="4469000" /> <workItem from="1584945647680" duration="4469000" />
<workItem from="1588148891822" duration="2318000" /> <workItem from="1588148891822" duration="2318000" />
<workItem from="1588152718016" duration="1463000" /> <workItem from="1588152718016" duration="1463000" />
<workItem from="1588154601852" duration="23750000" /> <workItem from="1588154601852" duration="24020000" />
</task> </task>
<servers /> <servers />
</component> </component>
......
...@@ -70,18 +70,15 @@ public class SparksqlServiceImpl implements SparksqlService { ...@@ -70,18 +70,15 @@ public class SparksqlServiceImpl implements SparksqlService {
} }
} }
String hql = sbf.toString(); String hql = sbf.toString();
Connection conn = null; Connection conn = null;
try{ try{
conn = DriverManager.getConnection(sparksqlJdbcUrl,"data",""); conn = DriverManager.getConnection(sparksqlJdbcUrl,"data","");
Statement statement = conn.createStatement(); Statement statement = conn.createStatement();
//Statement statement = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY);
ResultSet rs = statement.executeQuery(hql); ResultSet rs = statement.executeQuery(hql);
ResultSetMetaData metaData = rs.getMetaData(); ResultSetMetaData metaData = rs.getMetaData();
int columnCount = metaData.getColumnCount(); int columnCount = metaData.getColumnCount();
for(int i=1;i<= columnCount;i++){ for(int i=1;i<= columnCount;i++){
String columnName = metaData.getColumnName(i); String columnName = metaData.getColumnName(i);
//String catalogName = metaData.getCatalogName(i);
headers.add(columnName); headers.add(columnName);
} }
while(rs.next()){ while(rs.next()){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment