Skip to content

Commit c6b157a

Browse files
committed
refactor: add interface DatabendConnection.
1 parent 2c62fa7 commit c6b157a

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

48 files changed

+1537
-1454
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ The following example demonstrates how to upload data and load it into a table:
159159
```java
160160
// 1. Upload a file to the internal stage
161161
Connection conn = DriverManager.getConnection("jdbc:databend://localhost:8000");
162-
FileTransferAPI api = conn.unwrap(DatabendConnection.class);
162+
DatabendConnection api = conn.unwrap(DatabendConnection.class);
163163

164164
FileInputStream fileStream = new FileInputStream("data.csv");
165165
api.uploadStream(

databend-jdbc/src/main/java/com/databend/jdbc/Capability.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.vdurmont.semver4j.Semver;
44

5-
public class Capability {
5+
class Capability {
66
private final boolean streamingLoad;
77
private final boolean heartbeat;
88
public Capability(Semver ver) {

databend-jdbc/src/main/java/com/databend/jdbc/ConnectionProperties.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
import java.util.Set;
1010

1111
// all possible JDBC properties options currently supported by databend driver
12-
public final class ConnectionProperties {
12+
final class ConnectionProperties {
1313
public static final ConnectionProperty<String> USER = new User();
1414
public static final ConnectionProperty<String> PASSWORD = new Password();
1515
public static final ConnectionProperty<Boolean> SSL = new Ssl();

databend-jdbc/src/main/java/com/databend/jdbc/DatabendClientLoadBalancingPolicy.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import java.net.URI;
44
import java.util.List;
55

6-
public class DatabendClientLoadBalancingPolicy {
6+
class DatabendClientLoadBalancingPolicy {
77
static class DisabledPolicy extends DatabendClientLoadBalancingPolicy {
88
@Override
99
public String toString() {

databend-jdbc/src/main/java/com/databend/jdbc/DatabendColumnInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
import static java.util.Objects.requireNonNull;
1212

13-
public class DatabendColumnInfo {
13+
class DatabendColumnInfo {
1414
private static final int VARBINARY_MAX = 1024 * 1024 * 1024;
1515
// current longest time zone is 32
1616
private static final int TIME_ZONE_MAX = 40;

0 commit comments

Comments
 (0)