diff --git a/ExtendJar/opengauss-jdbc-5.0.0.jar b/ExtendJar/opengauss-jdbc-5.0.0.jar
new file mode 100644
index 0000000..1318002
Binary files /dev/null and b/ExtendJar/opengauss-jdbc-5.0.0.jar differ
diff --git a/pom.xml b/pom.xml
index bc2fd49..503a3e6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -50,6 +50,13 @@
system
${project.basedir}/ExtendJar/aspose.slides-19.3.jar
+
+ org.opengauss
+ opengauss-jdbc
+ 5.0.0
+ system
+ ${project.basedir}/ExtendJar/opengauss-jdbc-5.0.0.jar
+
com.jfinal
@@ -250,12 +257,6 @@
1.7.36
-
-
- org.opengauss
- opengauss-jdbc
- 5.0.0
-
org.apache.kafka
diff --git a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
index 9e44687..4c150c0 100644
--- a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
+++ b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java
@@ -22,13 +22,13 @@ import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
-import org.postgresql.PGProperty;
+import org.opengauss.PGProperty;
-import org.postgresql.jdbc.PgConnection;
+import org.opengauss.jdbc.PgConnection;
-import org.postgresql.replication.LogSequenceNumber;
+import org.opengauss.replication.LogSequenceNumber;
-import org.postgresql.replication.PGReplicationStream;
+import org.opengauss.replication.PGReplicationStream;
import java.nio.ByteBuffer;
diff --git a/src/main/java/UnitTest/TestReadWriteSplit.java b/src/main/java/UnitTest/TestReadWriteSplit.java
index 520ede5..6905735 100644
--- a/src/main/java/UnitTest/TestReadWriteSplit.java
+++ b/src/main/java/UnitTest/TestReadWriteSplit.java
@@ -42,9 +42,9 @@ public class TestReadWriteSplit {
}
public static void main(String[] args) {
- String MasterUrl = "jdbc:postgresql://10.10.14.61:15400/test_db";
- String SlaveUrl = "jdbc:postgresql://10.10.14.62:15400/test_db";
- String driverClass = "org.postgresql.Driver";
+ String MasterUrl = "jdbc:opengauss://10.10.14.61:15400/test_db";
+ String SlaveUrl = "jdbc:opengauss://10.10.14.62:15400/test_db";
+ String driverClass = "org.opengauss.Driver";
String userName = "postgres";
String passWord = "DsideaL147258369";
DruidPlugin dpMaster = createDruidPlugin(MasterUrl, userName, passWord, driverClass);
@@ -73,16 +73,16 @@ public class TestReadWriteSplit {
//启动
arp.start();
- String sql = "truncate table test";
- Db.update(sql);
+ //String sql = "truncate table test";
+ //Db.update(sql);
for (int i = 1; i <= 100; i++) {
- sql = "insert into test(id,txt) values(?,?)";
+ String sql = "insert into test(id,txt) values(?,?)";
Db.update(sql, i, "黄海——" + i);
}
for (int i = 1; i <= 100; i++) {
- sql = "select * from test where id=?";
+ String sql = "select * from test where id=?";
List list = Db.find(sql, i);
System.out.println(list);
}
diff --git a/src/main/java/UnitTest/TestReadWriteSplit2.java b/src/main/java/UnitTest/TestReadWriteSplit2.java
index 27f623c..620ee7e 100644
--- a/src/main/java/UnitTest/TestReadWriteSplit2.java
+++ b/src/main/java/UnitTest/TestReadWriteSplit2.java
@@ -42,8 +42,8 @@ public class TestReadWriteSplit2 {
}
public static void main(String[] args) {
- String url = "jdbc:postgresql://10.10.14.61:15400,10.10.14.62:15400/test_db?autoBalance=roundrobin&targetServerType=master";
- String driverClass = "org.postgresql.Driver";
+ String url = "jdbc:opengauss://10.10.14.61:15400,10.10.14.62:15400/test_db?autoBalance=roundrobin&targetServerType=master";
+ String driverClass = "org.opengauss.Driver";
String userName = "postgres";
String passWord = "DsideaL147258369";
DruidPlugin druidPlugin = createDruidPlugin(url, userName, passWord, driverClass);
@@ -55,7 +55,6 @@ public class TestReadWriteSplit2 {
arp.setDialect(new PostgreSqlDialect());
arp.start();
-
String sql = "truncate table test";
Db.update(sql);