feat(vastbase): replace JDBC agent with native Go driver

This commit is contained in:
t8y2
2026-08-03 23:09:11 +08:00
parent 05841277d1
commit dae150ea74
42 changed files with 6528 additions and 618 deletions
+2 -1
View File
@@ -48,9 +48,10 @@ const nativeDriverDirectories = {
duckdb: "duckdb",
oracle: "oracle-go",
kingbase: "kingbase-go",
vastbase: "vastbase-go",
rabbitmq: "rabbitmq",
};
const nativeDriverModules = new Set(["duckdb", "oracle", "xugu", "kingbase", "rabbitmq"]);
const nativeDriverModules = new Set(["duckdb", "oracle", "xugu", "kingbase", "vastbase", "rabbitmq"]);
function resolveAgentModule(moduleName, { legacyStandaloneModules, moduleExists, readModuleFile }) {
let checkDir = null;
@@ -45,6 +45,18 @@ test("bumps the native RabbitMQ agent from its Go directory", () => {
assert.equal(result.versions.rabbitmq, "0.1.1");
});
test("bumps the native Vastbase agent from its independent Go directory", () => {
const result = evaluateAgentVersionBump({
versions: { vastbase: "0.1.37" },
changedFiles: ["agents/drivers/vastbase-go/main.go"],
moduleExists: (path) => path === "agents/drivers/vastbase-go",
readModuleFile: () => "",
});
assert.equal(result.versions.vastbase, "0.1.38");
assert.deepEqual(result.nativeModules, ["vastbase"]);
});
test("builds a manually versioned module even without runtime file changes", () => {
const result = evaluateAgentVersionBump({
versions: { duckdb: "0.1.1" },
+1
View File
@@ -58,6 +58,7 @@ const DRIVER_DATABASE_ALIASES = {
rabbitmq: "mq",
rocketmq: "mq",
"sqlserver-legacy": "sqlserver",
"vastbase-go": "vastbase",
};
const DIALECT_DATABASE_ALIASES = {
+3 -1
View File
@@ -25,6 +25,7 @@ const knownDatabaseTypes = new Set([
"redis",
"sqlite",
"sqlserver",
"vastbase",
]);
test("labels a desktop MySQL UI fix", () => {
@@ -54,11 +55,12 @@ test("maps agent and dialect paths to existing database types", () => {
assert.deepEqual(
inferDatabaseTypes([
"agents/drivers/oracle-go/go.mod",
"agents/drivers/vastbase-go/go.mod",
"agents/drivers/kafka/build.gradle",
"plugins/dialects/postgresql.yaml",
"plugins/dialects/oceanbase.yaml",
], knownDatabaseTypes),
["mq", "oceanbase-oracle", "oracle", "postgres"],
["mq", "oceanbase-oracle", "oracle", "postgres", "vastbase"],
);
});
@@ -15,7 +15,7 @@ import { basename, join } from "node:path";
import { tmpdir } from "node:os";
const REGISTRY_ASSET = "agent-registry.json";
const NATIVE_MODULES = new Set(["duckdb", "oracle", "xugu", "kingbase", "rabbitmq"]);
const NATIVE_MODULES = new Set(["duckdb", "oracle", "xugu", "kingbase", "vastbase", "rabbitmq"]);
const PLATFORMS = [
"macos-aarch64",
"macos-x64",
@@ -44,16 +44,16 @@ test("collects complete reusable Java, native, and JRE assets", () => {
test("rejects an incomplete reusable native platform set", () => {
const native = Object.fromEntries(
platforms.slice(1).map((platform, index) => [platform, artifact(`dbx-agent-duckdb-0.1.2-${platform}.tar.zst`, String(index + 1))]),
platforms.slice(1).map((platform, index) => [platform, artifact(`dbx-agent-vastbase-0.1.38-${platform}.tar.zst`, String(index + 1))]),
);
const registry = { drivers: { duckdb: { version: "0.1.2", native } }, jres: {} };
const registry = { drivers: { vastbase: { version: "0.1.38", native } }, jres: {} };
assert.throws(
() => collectReusableAssetPlan({
registry,
release: releaseFor(Object.values(native)),
versions: { duckdb: "0.1.2" },
modules: ["duckdb"],
versions: { vastbase: "0.1.38" },
modules: ["vastbase"],
reuseJre: false,
}),
/missing=macos-aarch64/,
+46 -2
View File
@@ -316,6 +316,46 @@ jobs:
name: kingbase-native
path: "release-native/dbx-agent-kingbase-*"
build-vastbase-native:
needs: [bump-versions]
if: ${{ contains(fromJSON(needs.bump-versions.outputs.native_modules), 'vastbase') }}
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v4
- uses: actions/setup-go@v5
with:
go-version: "1.22.x"
- name: Test Vastbase native agent
working-directory: agents/drivers/vastbase-go
run: go test ./...
- name: Cross-compile Vastbase native agent
shell: bash
run: |
mkdir -p release-native
cd agents/drivers/vastbase-go
declare -A TARGETS=(
["macos-aarch64"]="darwin/arm64"
["macos-x64"]="darwin/amd64"
["linux-aarch64"]="linux/arm64"
["linux-x64"]="linux/amd64"
["windows-aarch64"]="windows/arm64"
["windows-x64"]="windows/amd64"
)
for platform in "${!TARGETS[@]}"; do
IFS=/ read -r goos goarch <<< "${TARGETS[$platform]}"
output="../../../release-native/dbx-agent-vastbase-${platform}"
if [[ "$goos" == "windows" ]]; then
output="${output}.exe"
fi
echo "Building $platform ($goos/$goarch)"
CGO_ENABLED=0 GOOS="$goos" GOARCH="$goarch" go build -trimpath -ldflags="-s -w" -o "$output" .
done
ls -lh ../../../release-native
- uses: actions/upload-artifact@v4
with:
name: vastbase-native
path: "release-native/dbx-agent-vastbase-*"
build-duckdb-native:
needs: [bump-versions]
if: ${{ contains(fromJSON(needs.bump-versions.outputs.native_modules), 'duckdb') }}
@@ -531,7 +571,7 @@ jobs:
retention-days: 1
release:
needs: [bump-versions, commit-versions, build-agents, build-oracle-native, build-xugu-native, build-rabbitmq-native, build-kingbase-native, build-duckdb-native, build-jre, reuse-previous-assets]
needs: [bump-versions, commit-versions, build-agents, build-oracle-native, build-xugu-native, build-rabbitmq-native, build-kingbase-native, build-vastbase-native, build-duckdb-native, build-jre, reuse-previous-assets]
if: ${{ always() && !contains(needs.*.result, 'failure') && !contains(needs.*.result, 'cancelled') }}
runs-on: ubuntu-latest
steps:
@@ -649,6 +689,7 @@ jobs:
local name="$1"
case "$name" in
kingbase) echo "人大金仓 KingbaseES" ;;
vastbase) echo "Vastbase" ;;
duckdb) echo "DuckDB" ;;
xugu) echo "虚谷 XuguDB" ;;
rabbitmq) echo "RabbitMQ" ;;
@@ -715,7 +756,7 @@ jobs:
[ -n "$DRIVERS" ] && DRIVERS="${DRIVERS},"$'\n'
DRIVERS="${DRIVERS}$(generate_jar_entry "$name" "$label" "$f" "$jre_key" "$version" "$external_driver" "$native_json")"
done
for name in oracle xugu kingbase duckdb rabbitmq; do
for name in oracle xugu kingbase vastbase duckdb rabbitmq; do
version=$(get_module_version "$name")
[ -f "release/dbx-agent-${name}-${version}.jar" ] && continue
native_json=$(generate_native_platforms "$name" "$version")
@@ -780,6 +821,7 @@ jobs:
local name="$1"
case "$name" in
kingbase) echo "人大金仓 KingbaseES" ;;
vastbase) echo "Vastbase" ;;
duckdb) echo "DuckDB" ;;
oracle) echo "Oracle" ;;
xugu) echo "虚谷 XuguDB" ;;
@@ -806,6 +848,8 @@ jobs:
LOG_PATH="agents/drivers/oracle-go/"
elif [ "$name" = "kingbase" ]; then
LOG_PATH="agents/drivers/kingbase-go/"
elif [ "$name" = "vastbase" ]; then
LOG_PATH="agents/drivers/vastbase-go/"
elif [ -d "agents/drivers/$name" ]; then
LOG_PATH="agents/drivers/$name/"
else
+8
View File
@@ -538,6 +538,10 @@ jobs:
run: go test ./...
working-directory: agents/drivers/rabbitmq
- name: Vastbase native agent tests
run: go test ./...
working-directory: agents/drivers/vastbase-go
- name: Oracle native agent build
run: CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -trimpath -ldflags="-s -w" -o /tmp/dbx-agent-oracle-linux-x64 .
working-directory: agents/drivers/oracle-go
@@ -550,6 +554,10 @@ jobs:
run: CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -trimpath -ldflags="-s -w" -o /tmp/dbx-agent-rabbitmq-linux-x64 .
working-directory: agents/drivers/rabbitmq
- name: Vastbase native agent build
run: CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -trimpath -ldflags="-s -w" -o /tmp/dbx-agent-vastbase-linux-x64 .
working-directory: agents/drivers/vastbase-go
- name: RabbitMQ native agent integration tests
shell: bash
working-directory: agents/drivers/rabbitmq