/
Examples.java
87 lines (79 loc) · 3.39 KB
/
Examples.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package com.databend.jdbc.examples;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
class Examples {
private static Connection createConnection()
throws SQLException {
String url = "jdbc:databend://localhost:8000";
return DriverManager.getConnection(url, "databend", "databend");
}
public static void main(String[] args) throws SQLException {
// set up
Connection c = createConnection();
System.out.println("-----------------");
System.out.println("drop all existing test table");
// execute demo
c.createStatement().execute("drop table if exists test_prepare_statement");
c.createStatement().execute("create table test_prepare_statement (a int, b string)");
// insert into with PreparedStatement
String sql = "insert into test_prepare_statement values (?,?)";
Connection conn = createConnection();
try (PreparedStatement statement = conn.prepareStatement(sql)) {
statement.setInt(1, 1);
statement.setString(2, "b");
statement.addBatch();
int[] result = statement.executeBatch();
System.out.println(result);
}
// update with PreparedStatement
String updateSQL = "update test_prepare_statement set b = ? where a = ?";
try (PreparedStatement statement = conn.prepareStatement(updateSQL)) {
statement.setInt(2, 1);
// Attention: now setString(1, "c") will throw exception, need to setString(1, "'c'")
statement.setString(1, "c");
int result = statement.executeUpdate();
System.out.println(result);
}
// executeQuery and return ResultSet
ResultSet r = conn.createStatement().executeQuery("select * from test_prepare_statement");
while (r.next()) {
System.out.println(r.getInt(1));
System.out.println(r.getString(2));
}
// replace into with PreparedStatement
String replaceIntoSQL = "replace into test_prepare_statement on(a) values (?,?)";
try (PreparedStatement statement = conn.prepareStatement(replaceIntoSQL)) {
statement.setInt(1, 1);
statement.setString(2, "d");
statement.addBatch();
int[] result = statement.executeBatch();
}
ResultSet r2 = conn.createStatement().executeQuery("select * from test_prepare_statement");
while (r2.next()) {
System.out.println(r2.getInt(1));
System.out.println(r2.getString(2));
}
// delete with PreparedStatement
String deleteSQL = "delete from test_prepare_statement where a = ?";
try (PreparedStatement statement = conn.prepareStatement(deleteSQL)) {
statement.setInt(1, 1);
int result = statement.executeUpdate();
System.out.println(result);
}
ResultSet r3 = conn.createStatement().executeQuery("select * from test_prepare_statement");
// Assert.assertEquals(0, r3.getRow());
while (r3.next()) {
// noting print
System.out.println(r3.getInt(1));
System.out.println(r3.getString(2));
}
}
}