github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-16 00:41:23 +08:00
Code Issues Projects Releases Wiki Activity

SQOOP-980: Sqoop2: Show connection and job command hung

Browse Source 
(Vasanth kumar RJ via Jarek Jarcec Cecho)
This commit is contained in:
Jarek Jarcec Cecho 2013-04-13 15:03:52 -07:00
parent 6ceb22497c
commit c4ddeb7ff7
1 changed files with 8 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
repository/repository-derby/src/main/java/org/apache/sqoop/repository/derby/DerbyRepositoryHandler.java
View File

@ -1180,6 +1180,10 @@ private List<MConnection> loadConnections(PreparedStatement stmt,
try { try {
rsConnection = stmt.executeQuery(); rsConnection = stmt.executeQuery();
formConnectorFetchStmt = conn.prepareStatement(STMT_FETCH_FORM_CONNECTOR);
formFrameworkFetchStmt = conn.prepareStatement(STMT_FETCH_FORM_FRAMEWORK);
inputFetchStmt = conn.prepareStatement(STMT_FETCH_CONNECTION_INPUT);
while(rsConnection.next()) { while(rsConnection.next()) {
long id = rsConnection.getLong(1); long id = rsConnection.getLong(1);
String name = rsConnection.getString(2); String name = rsConnection.getString(2);
@ -1187,14 +1191,8 @@ private List<MConnection> loadConnections(PreparedStatement stmt,
Date creationDate = rsConnection.getTimestamp(4); Date creationDate = rsConnection.getTimestamp(4);
Date lastUpdateDate = rsConnection.getTimestamp(5); Date lastUpdateDate = rsConnection.getTimestamp(5);
formConnectorFetchStmt =
conn.prepareStatement(STMT_FETCH_FORM_CONNECTOR);
formConnectorFetchStmt.setLong(1, connectorId); formConnectorFetchStmt.setLong(1, connectorId);
formFrameworkFetchStmt =
conn.prepareStatement(STMT_FETCH_FORM_FRAMEWORK);
inputFetchStmt = conn.prepareStatement(STMT_FETCH_CONNECTION_INPUT);
inputFetchStmt.setLong(1, id); inputFetchStmt.setLong(1, id);
//inputFetchStmt.setLong(2, XXX); // Will be filled by loadForms //inputFetchStmt.setLong(2, XXX); // Will be filled by loadForms
inputFetchStmt.setLong(3, id); inputFetchStmt.setLong(3, id);
@ -1244,6 +1242,10 @@ private List<MJob> loadJobs(PreparedStatement stmt,
try { try {
rsJob = stmt.executeQuery(); rsJob = stmt.executeQuery();
formConnectorFetchStmt = conn.prepareStatement(STMT_FETCH_FORM_CONNECTOR);
formFrameworkFetchStmt = conn.prepareStatement(STMT_FETCH_FORM_FRAMEWORK);
inputFetchStmt = conn.prepareStatement(STMT_FETCH_JOB_INPUT);
while(rsJob.next()) { while(rsJob.next()) {
long connectorId = rsJob.getLong(1); long connectorId = rsJob.getLong(1);
long id = rsJob.getLong(2); long id = rsJob.getLong(2);
@ -1255,14 +1257,8 @@ private List<MJob> loadJobs(PreparedStatement stmt,
MJob.Type type = MJob.Type.valueOf(stringType); MJob.Type type = MJob.Type.valueOf(stringType);
formConnectorFetchStmt =
conn.prepareStatement(STMT_FETCH_FORM_CONNECTOR);
formConnectorFetchStmt.setLong(1, connectorId); formConnectorFetchStmt.setLong(1, connectorId);
formFrameworkFetchStmt =
conn.prepareStatement(STMT_FETCH_FORM_FRAMEWORK);
inputFetchStmt = conn.prepareStatement(STMT_FETCH_JOB_INPUT);
inputFetchStmt.setLong(1, id); inputFetchStmt.setLong(1, id);
//inputFetchStmt.setLong(1, XXX); // Will be filled by loadForms //inputFetchStmt.setLong(1, XXX); // Will be filled by loadForms
inputFetchStmt.setLong(3, id); inputFetchStmt.setLong(3, id);