github/dbx
4
0
Fork 0
mirror of https://github.com/t8y2/dbx.git synced 2026-10-19 16:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(agent): disable reconnect in large-value proxy fixtures

Browse Source
This commit is contained in:
efeire
2026-10-10 09:07:54 +08:00
parent d4e498184b
commit a4a82f2c39
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agents/common/src/test/java/com/dbx/agent/JsonRpcLargeValueTest.java
+3
View File
@@ -15,6 +15,7 @@ class JsonRpcLargeValueTest {
DatabaseAgent agent = (DatabaseAgent) Proxy.newProxyInstance(DatabaseAgent.class.getClassLoader(),
new Class<?>[]{DatabaseAgent.class}, (object, method, args) -> {
if (method.getName().equals("supportsQueryTiming")) return false;
if (method.getName().equals("permitsAutomaticReconnect")) return false;
if (method.getName().equals("readLargeValueChunk")) {
calls.add("read");
assertArrayEquals(new Object[]{"opaque-original", 700L, 4096}, args);
@@ -38,6 +39,7 @@ class JsonRpcLargeValueTest {
DatabaseAgent agent = (DatabaseAgent) Proxy.newProxyInstance(DatabaseAgent.class.getClassLoader(),
new Class<?>[]{DatabaseAgent.class}, (object, method, args) -> {
if (method.getName().equals("supportsQueryTiming")) return false;
if (method.getName().equals("permitsAutomaticReconnect")) return false;
if (method.getName().equals("invalidateLargeValues")) { calls.add("invalidate"); return null; }
if (method.getName().equals("commitManualTransaction")) { calls.add("commit"); return Map.of("ok", true); }
return null;
@@ -53,6 +55,7 @@ class JsonRpcLargeValueTest {
DatabaseAgent agent = (DatabaseAgent) Proxy.newProxyInstance(DatabaseAgent.class.getClassLoader(),
new Class<?>[]{DatabaseAgent.class}, (object, method, args) -> {
if (method.getName().equals("supportsQueryTiming")) return false;
if (method.getName().equals("permitsAutomaticReconnect")) return false;
if (method.getName().equals("invalidateLargeValues")) { calls.add("invalidate"); return null; }
if (method.getName().equals("executeBatch")) { calls.add("write"); throw new java.sql.SQLException("concurrent row removed"); }
if (method.getName().equals("rollbackManualTransaction")) { calls.add("rollback"); return Map.of("ok", true); }