pt/jrunner
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 5 Wiki Activity

Compare commits

base: pt:efd922b2e09f6cee34b5b443f41de7244245296f
Branches Tags
pt:master
pt:testread
pt:v0.41
pt:v0.40
pt:v0.38
pt:v0.36
pt:v0.35
pt:v0.34
pt:v0.33
pt:v0.32
pt:v0.31
pt:v0.30
pt:v0.29
pt:v0.28
..
compare: pt:0615163fad64d25e2a2f931eaa1e83e4e0be0944
Branches Tags
pt:master
pt:testread
pt:v0.41
pt:v0.40
pt:v0.38
pt:v0.36
pt:v0.35
pt:v0.34
pt:v0.33
pt:v0.32
pt:v0.31
pt:v0.30
pt:v0.29
pt:v0.28

No commits in common. "efd922b2e09f6cee34b5b443f41de7244245296f" and "0615163fad64d25e2a2f931eaa1e83e4e0be0944" have entirely different histories.
efd922b2e0 ... 0615163fad

1 changed files with 6 additions and 12 deletions
Show Stats Expand all files Collapse all files

18
app/src/main/java/jrunner/jrunner.java
View File

@ -35,7 +35,7 @@ public class jrunner {
Integer cols = null; Integer cols = null;
String[] dtn = null; String[] dtn = null;
msg = "jrunner version 0.36"; msg = "jrunner version 0.35";
msg = msg + nl + "-scu source jdbc url"; msg = msg + nl + "-scu source jdbc url";
msg = msg + nl + "-scn source username"; msg = msg + nl + "-scn source username";
msg = msg + nl + "-scp source passowrd"; msg = msg + nl + "-scp source passowrd";
@ -161,7 +161,6 @@ public class jrunner {
//----------------------------------------open resultset------------------------------------------------------------ //----------------------------------------open resultset------------------------------------------------------------
try { try {
stmt = scon.createStatement(); stmt = scon.createStatement();
stmt.setFetchSize(10000);
rs = stmt.executeQuery(sq); rs = stmt.executeQuery(sq);
//while (rs.next()) { //while (rs.next()) {
// System.out.println(rs.getString("x")); // System.out.println(rs.getString("x"));
@ -202,32 +201,29 @@ public class jrunner {
for (int i = 1; i <= cols; i++){ for (int i = 1; i <= cols; i++){
switch (dtn[i]){ switch (dtn[i]){
case "VARCHAR": case "VARCHAR":
nc = rs.getString(i); nc = rs.getString(i).replace("'","''");
if (rs.wasNull() || nc == null) { if (rs.wasNull() || nc == null) {
nc = "NULL"; nc = "NULL";
break; break;
} }
nc.replace("'","''");
if (trim) { nc = nc.trim();} if (trim) { nc = nc.trim();}
nc = "'" + nc + "'"; nc = "'" + nc + "'";
break; break;
case "CLOB": case "CLOB":
nc = rs.getString(i); nc = rs.getString(i).replace("'","''");
if (rs.wasNull() || nc == null) { if (rs.wasNull() || nc == null) {
nc = "NULL"; nc = "NULL";
break; break;
} }
nc.replace("'","''");
if (trim) { nc = nc.trim();} if (trim) { nc = nc.trim();}
nc = "'" + nc + "'"; nc = "'" + nc + "'";
break; break;
case "CHAR": case "CHAR":
nc = rs.getString(i); nc = rs.getString(i).replace("'","''");
if (rs.wasNull() || nc == null) { if (rs.wasNull() || nc == null) {
nc = "NULL"; nc = "NULL";
break; break;
} }
nc.replace("'","''");
if (trim) { nc = nc.trim();} if (trim) { nc = nc.trim();}
nc = "'" + nc + "'"; nc = "'" + nc + "'";
break; break;
@ -243,21 +239,19 @@ public class jrunner {
} }
break; break;
case "TIME": case "TIME":
nc = rs.getString(i); nc = rs.getString(i).replace("'","''");
if (rs.wasNull() || nc == null) { if (rs.wasNull() || nc == null) {
nc = "NULL"; nc = "NULL";
break; break;
} }
nc.replace("'","''");
nc = "'" + nc + "'"; nc = "'" + nc + "'";
break; break;
case "TIMESTAMP": case "TIMESTAMP":
nc = rs.getString(i); nc = rs.getString(i).replace("'","''");
if (rs.wasNull() || nc == null) { if (rs.wasNull() || nc == null) {
nc = "NULL"; nc = "NULL";
break; break;
} }
nc.replace("'","''");
nc = "'" + nc + "'"; nc = "'" + nc + "'";
break; break;
case "BIGINT": case "BIGINT":