Lines 108-113
Link Here
|
108 |
static final String AUTOCOMMIT_FALSE = "AutoCommit(false)"; // $NON-NLS-1$ |
108 |
static final String AUTOCOMMIT_FALSE = "AutoCommit(false)"; // $NON-NLS-1$ |
109 |
static final String AUTOCOMMIT_TRUE = "AutoCommit(true)"; // $NON-NLS-1$ |
109 |
static final String AUTOCOMMIT_TRUE = "AutoCommit(true)"; // $NON-NLS-1$ |
110 |
|
110 |
|
|
|
111 |
static final String RS_STORE_AS_STRING = "Store as String"; // $NON-NLS-1$ |
112 |
static final String RS_STORE_AS_OBJECT = "Store as Object"; // $NON-NLS-1$ |
113 |
static final String RS_COUNT_RECORDS = "Count Records"; // $NON-NLS-1$ |
114 |
|
111 |
private String query = ""; // $NON-NLS-1$ |
115 |
private String query = ""; // $NON-NLS-1$ |
112 |
|
116 |
|
113 |
private String dataSource = ""; // $NON-NLS-1$ |
117 |
private String dataSource = ""; // $NON-NLS-1$ |
Lines 116-121
Link Here
|
116 |
private String queryArguments = ""; // $NON-NLS-1$ |
120 |
private String queryArguments = ""; // $NON-NLS-1$ |
117 |
private String queryArgumentsTypes = ""; // $NON-NLS-1$ |
121 |
private String queryArgumentsTypes = ""; // $NON-NLS-1$ |
118 |
private String variableNames = ""; // $NON-NLS-1$ |
122 |
private String variableNames = ""; // $NON-NLS-1$ |
|
|
123 |
private String resultSetHandler = RS_STORE_AS_STRING; |
119 |
private String resultVariable = ""; // $NON-NLS-1$ |
124 |
private String resultVariable = ""; // $NON-NLS-1$ |
120 |
private String queryTimeout = ""; // $NON-NLS-1$ |
125 |
private String queryTimeout = ""; // $NON-NLS-1$ |
121 |
|
126 |
|
Lines 242-247
Link Here
|
242 |
sb.append(i+1); |
247 |
sb.append(i+1); |
243 |
sb.append("] "); |
248 |
sb.append("] "); |
244 |
sb.append(o); |
249 |
sb.append(o); |
|
|
250 |
if( o instanceof java.sql.ResultSet && RS_COUNT_RECORDS.equals(resultSetHandler)) { |
251 |
int j=0; |
252 |
while(((java.sql.ResultSet)o).next()) |
253 |
j++; |
254 |
sb.append(" "+j+" rows"); |
255 |
} |
245 |
sb.append("\n"); |
256 |
sb.append("\n"); |
246 |
} |
257 |
} |
247 |
} |
258 |
} |
Lines 252-258
Link Here
|
252 |
String name = varnames[i].trim(); |
263 |
String name = varnames[i].trim(); |
253 |
if (name.length()>0){ // Save the value in the variable if present |
264 |
if (name.length()>0){ // Save the value in the variable if present |
254 |
Object o = outputValues.get(i); |
265 |
Object o = outputValues.get(i); |
255 |
jmvars.put(name, o == null ? null : o.toString()); |
266 |
if( o instanceof java.sql.ResultSet ) |
|
|
267 |
if( RS_STORE_AS_OBJECT.equals(resultSetHandler)) |
268 |
jmvars.putObject(name, o); |
269 |
else if( RS_COUNT_RECORDS.equals(resultSetHandler)) |
270 |
jmvars.put(name,o.toString()+" "+((java.sql.ResultSet)o).getRow()+" rows"); |
271 |
else |
272 |
jmvars.put(name, o.toString()); |
273 |
else |
274 |
jmvars.put(name, o == null ? null : o.toString()); |
256 |
} |
275 |
} |
257 |
} |
276 |
} |
258 |
} |
277 |
} |
Lines 596-601
Link Here
|
596 |
} |
615 |
} |
597 |
|
616 |
|
598 |
/** |
617 |
/** |
|
|
618 |
* @return the resultSetHandler |
619 |
*/ |
620 |
public String getResultSetHandler() { |
621 |
return resultSetHandler; |
622 |
} |
623 |
|
624 |
/** |
625 |
* @param resultSetHandler the resultSetHandler to set |
626 |
*/ |
627 |
public void setResultSetHandler(String resultSetHandler) { |
628 |
this.resultSetHandler = resultSetHandler; |
629 |
} |
630 |
|
631 |
/** |
599 |
* @return the resultVariable |
632 |
* @return the resultVariable |
600 |
*/ |
633 |
*/ |
601 |
public String getResultVariable() { |
634 |
public String getResultVariable() { |