Changeset: d7bac8d0fb93 for monetdb-java
URL: https://dev.monetdb.org/hg/monetdb-java?cmd=changeset;node=d7bac8d0fb93
Modified Files:
tests/JDBC_API_Tester.java
Branch: default
Log Message:
Converted and added example program SQLcopyinto() to JDBC_API_Tester.java
diffs (truncated from 1283 to 300 lines):
diff --git a/tests/JDBC_API_Tester.java b/tests/JDBC_API_Tester.java
--- a/tests/JDBC_API_Tester.java
+++ b/tests/JDBC_API_Tester.java
@@ -94,6 +94,7 @@ final public class JDBC_API_Tester {
jt.Bug_PrepStmt_With_Errors_Jira292();
jt.BugResultSetMetaData_Bug_6183();
jt.BugSetQueryTimeout_Bug_3357();
+ jt.SQLcopyinto();
jt.closeConx(jt.con);
}
@@ -252,7 +253,7 @@ final public class JDBC_API_Tester {
stmt = con.createStatement();
// sending big script with many simple queries
- sb.append("1. executing script").append("\n");
+ sb.append("1. executing script\n");
stmt.execute(bigq.toString());
int i = 1; // we skip the first "getResultSet()"
@@ -260,12 +261,12 @@ final public class JDBC_API_Tester {
i++;
}
if (stmt.getUpdateCount() != -1) {
- sb.append("Error: found an update count for a
SELECT query").append("\n");
+ sb.append("Error: found an update count for a
SELECT query\n");
}
if (i != size) {
sb.append("Error: expecting
").append(size).append(" tuples, only got ").append(i).append("\n");
}
- sb.append("2. queries processed").append("\n");
+ sb.append("2. queries processed\n");
} catch (SQLException e) {
sb.append("FAILED:
").append(e.getMessage()).append("\n");
}
@@ -345,16 +346,16 @@ final public class JDBC_API_Tester {
// test commit by checking if a change is visible in
another connection
sb.append("1. create... ");
stmt1.executeUpdate("CREATE TABLE table_Test_Creplysize
( id int )");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("2. populating with 21 records... ");
for (int i = 0; i < 21; i++)
stmt1.executeUpdate("INSERT INTO
table_Test_Creplysize (id) values (" + (i + 1) + ")");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("3. hinting the driver to use fetchsize 10...
");
stmt1.setFetchSize(10);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("4. selecting all values... ");
rs = stmt1.executeQuery("SELECT * FROM
table_Test_Creplysize");
@@ -371,11 +372,11 @@ final public class JDBC_API_Tester {
sb.append("5. resetting driver fetchsize hint... ");
stmt1.setFetchSize(0);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("6. instructing the driver to return at max
10 rows... ");
stmt1.setMaxRows(10);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("7. selecting all values... ");
rs = stmt1.executeQuery("SELECT * FROM
table_Test_Creplysize");
@@ -392,7 +393,7 @@ final public class JDBC_API_Tester {
sb.append("8. hinting the driver to use fetchsize 5...
");
stmt1.setFetchSize(5);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("9. selecting all values... ");
rs = stmt1.executeQuery("SELECT * FROM
table_Test_Creplysize");
@@ -409,7 +410,7 @@ final public class JDBC_API_Tester {
sb.append("10. drop... ");
stmt1.executeUpdate("DROP TABLE table_Test_Creplysize");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
con.rollback();
@@ -461,14 +462,14 @@ final public class JDBC_API_Tester {
sb.append("2. savepoint...");
/* make a savepoint, and discard it */
con.setSavepoint();
- sb.append("passed").append("\n");
+ sb.append("passed\n");
stmt = con.createStatement();
stmt.executeUpdate("CREATE TABLE table_Test_Csavepoints
( id int, PRIMARY KEY (id) )");
sb.append("3. savepoint...");
Savepoint sp2 = con.setSavepoint("empty table");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
rs = stmt.executeQuery("SELECT id FROM
table_Test_Csavepoints");
int i = 0;
@@ -481,7 +482,7 @@ final public class JDBC_API_Tester {
if (i != items) {
sb.append(" FAILED (").append(i).append(")");
}
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
stmt.executeUpdate("INSERT INTO table_Test_Csavepoints
VALUES (1)");
stmt.executeUpdate("INSERT INTO table_Test_Csavepoints
VALUES (2)");
@@ -489,7 +490,7 @@ final public class JDBC_API_Tester {
sb.append("5. savepoint...");
Savepoint sp3 = con.setSavepoint("three values");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
rs = stmt.executeQuery("SELECT id FROM
table_Test_Csavepoints");
i = 0;
@@ -502,11 +503,11 @@ final public class JDBC_API_Tester {
if (i != items) {
sb.append(" FAILED (").append(i).append(")");
}
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
sb.append("7. release...");
con.releaseSavepoint(sp3);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
rs = stmt.executeQuery("SELECT id FROM
table_Test_Csavepoints");
i = 0;
@@ -519,11 +520,11 @@ final public class JDBC_API_Tester {
if (i != items) {
sb.append(" FAILED (").append(i).append(") :(");
}
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
sb.append("9. rollback...");
con.rollback(sp2);
- sb.append("passed").append("\n");
+ sb.append("passed\n");
rs = stmt.executeQuery("SELECT id FROM
table_Test_Csavepoints");
i = 0;
@@ -586,11 +587,11 @@ final public class JDBC_API_Tester {
// a change would not be visible now
sb.append("3. commit...");
con.commit();
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("4. commit...");
con.commit();
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("5. rollback...");
con.rollback();
@@ -610,22 +611,22 @@ final public class JDBC_API_Tester {
stmt = con.createStatement();
sb.append("7. start transaction...");
stmt.executeUpdate("START TRANSACTION");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("8. commit...");
con.commit();
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("9. true\t").append(con.getAutoCommit());
sb.append("\n");
sb.append("10. start transaction...");
stmt.executeUpdate("START TRANSACTION");
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("11. rollback...");
con.rollback();
- sb.append("passed").append("\n");
+ sb.append("passed\n");
sb.append("12. true\t").append(con.getAutoCommit());
} catch (SQLException e) {
@@ -758,7 +759,7 @@ final public class JDBC_API_Tester {
ResultSetMetaData rsmd = rs.getMetaData();
int columnCount = rsmd.getColumnCount();
- sb.append("Resultset with ").append(columnCount).append("
columns").append("\n");
+ sb.append("Resultset with ").append(columnCount).append("
columns\n");
for (int col = 1; col <= columnCount; col++) {
if (col > 1)
sb.append("\t");
@@ -858,7 +859,7 @@ final public class JDBC_API_Tester {
rs.close();
sb.append("Expecting " + bi + ", got " +
biRes).append("\n");
if (!bi.equals(biRes)) {
- sb.append("value of bi is NOT equal to
biRes!").append("\n");
+ sb.append("value of bi is NOT equal to
biRes!\n");
}
rs = stmt.executeQuery("SELECT I FROM HUGEDECT");
@@ -867,7 +868,7 @@ final public class JDBC_API_Tester {
rs.close();
sb.append("Expecting " + bd + ", got " +
bdRes).append("\n");
if (!bd.equals(bdRes)) {
- sb.append("value of bd is NOT equal to
bdRes!").append("\n");
+ sb.append("value of bd is NOT equal to
bdRes!\n");
}
} catch (SQLException e) {
sb.append("FAILED:
").append(e.getMessage()).append("\n");
@@ -877,7 +878,7 @@ final public class JDBC_API_Tester {
try {
stmt.executeUpdate("DROP TABLE IF EXISTS HUGEINTT");
stmt.executeUpdate("DROP TABLE IF EXISTS HUGEDECT");
- sb.append("SUCCESS").append("\n");
+ sb.append("SUCCESS\n");
} catch (SQLException e) {
sb.append("FAILED:
").append(e.getMessage()).append("\n");
}
@@ -922,19 +923,19 @@ final public class JDBC_API_Tester {
pstmt.executeUpdate();
pstmt.executeUpdate();
pstmt.executeUpdate();
- sb.append("success").append("\n");
+ sb.append("success\n");
// now get the generated keys
sb.append("2. getting generated keys...");
keys = pstmt.getGeneratedKeys();
if (keys == null) {
- sb.append("there are no keys!").append("\n");
+ sb.append("there are no keys!\n");
} else {
while (keys.next()) {
sb.append("generated key index:
").append(keys.getInt(1)).append("\n");
}
if (keys.getStatement() == null) {
- sb.append("ResultSet.getStatement()
should never return null!").append("\n");
+ sb.append("ResultSet.getStatement()
should never return null!\n");
}
keys.close();
}
@@ -970,7 +971,7 @@ final public class JDBC_API_Tester {
stmt = con.createStatement();
sb.append("1. creating test table...");
stmt.executeUpdate("CREATE TABLE table_Test_PSgetObject
(ti tinyint, si smallint, i int, bi bigint)");
- sb.append("success").append("\n");
+ sb.append("success\n");
stmt.close();
} catch (SQLException e) {
sb.append("FAILED:
").append(e.getMessage()).append("\n");
@@ -1001,11 +1002,11 @@ final public class JDBC_API_Tester {
pstmt.addBatch();
pstmt.executeBatch();
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
sb.append("2b. closing PreparedStatement...");
pstmt.close();
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
} catch (SQLException e) {
sb.append("FAILED to INSERT data:
").append(e.getMessage()).append("\n");
while ((e = e.getNextException()) != null)
@@ -1016,7 +1017,7 @@ final public class JDBC_API_Tester {
sb.append("3a. selecting records...");
pstmt = con.prepareStatement("SELECT ti,si,i,bi FROM
table_Test_PSgetObject ORDER BY ti,si,i,bi");
rs = pstmt.executeQuery();
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
while (rs.next()) {
// test fix for
https://www.monetdb.org/bugzilla/show_bug.cgi?id=4026
@@ -1030,11 +1031,11 @@ final public class JDBC_API_Tester {
sb.append("3b. closing ResultSet...");
rs.close();
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
sb.append("3c. closing PreparedStatement...");
pstmt.close();
- sb.append(" passed").append("\n");
+ sb.append(" passed\n");
} catch (SQLException e) {
sb.append("FAILED to RETRIEVE data:
").append(e.getMessage()).append("\n");
while ((e = e.getNextException()) != null)
@@ -1045,7 +1046,7 @@ final public class JDBC_API_Tester {
try {
sb.append("4. Rollback changes...");
con.rollback();
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list
