当前位置：首页 > news >正文

多数据库学习之VastbaseG100海量数据库入门实践

news 2025/8/1 19:15:24

多数据库学习之VastbaseG100海量数据库入门实践

简介
- 软件架构
连接数据库
兼容模式
操作数据库
- DDL语法
参考链接

简介

软件架构

概述

Vastbase G100 是集中式数据库系统，在这样的系统架构中，业务数据存储在单个物理节点上，数据访问任务被推送到服务节点执行，通过服务器的高并发，实现对数据处理的快速响应。同时通过日志复制可以把数据复制到备机，提供数据的高可靠和读扩展。

vastbaseg100数据库架构图

名称	描述
APP	业务应用
DRV	数据库驱动
Master	Vastbase G100主服务节点，数据访问任务的接收节点，支持高并发。
Slave	备份，通过同步复制与主机数据保持同步，用于提供数据的高可靠和读扩展。

连接数据库

加载驱动

驱动包详见海量数据库Vastbase G100 JDBC 驱动

Class.forName("org.postgresql.Driver");

如果使用 p 版本驱动，则连接串使用org.postgresql.Driver；

如果使用 v 版本驱动，则连接串使用cn.com.vastbase.Driver。

URL格式

jdbc:postgresql://host:port/database
jdbc:postgresql://host:port/
jdbc:postgresql://host/database
jdbc:postgresql://host/
jdbc:postgresql:/
jdbc:postgresql://host:port/database?param1=value1&param2=value2

注意：

如果使用 p 版本驱动，则连接串使用jdbc:postgresql；
如果使用 v 版本驱动，则连接串使用jdbc:vastbase。

示例代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;public class testConn{static Connection conn = null;static String cname = "cn.com.vastbase.Driver";static String url = "jdbc:vastbase://172.16.xxx.xxx:xxx/postgres?loggerLevel=OFF";static String username = "Vastbase";static String passwd = "Vbase@123";public static void main(String[] args){try{Class.forName(cname);conn = DriverManager.getConnection(url,username,passwd);System.out.println("[SUCCESS] conn database success.");}catch (Exception e){System.out.println("[FAIL] conn database fail." + e.getMessage());}}public void disConn(Connection conn) throws SQLException{if(conn != null){conn.close();}}
}

兼容模式

实例兼容模式(非实例化安装无此步骤)

可选值为A、B、PG、MSSQL。分别表示兼容Oracle、MySQL、PostgreSQL和SQL Server。默认为Oracle兼容模式。

操作数据库

DDL语法

创建表

CREATE TABLE warehouse_t1
(W_WAREHOUSE_SK    INTEGER  NOT NULL,W_WAREHOUSE_ID    CHAR(16) NOT NULL,W_WAREHOUSE_NAME  VARCHAR(20),W_WAREHOUSE_SQ_FT INTEGER,W_STREET_NUMBER   CHAR(10),W_STREET_NAME     VARCHAR(60),W_STREET_TYPE     CHAR(15),W_SUITE_NUMBER    CHAR(10),W_CITY            VARCHAR(60),W_COUNTY          VARCHAR(30),W_STATE           CHAR(2),W_ZIP             CHAR(10),W_COUNTRY         VARCHAR(20),W_GMT_OFFSET      DECIMAL(5, 2),primary key (W_WAREHOUSE_ID)
);

管理函数

-- 创建函数
CREATE OR REPLACE FUNCTION func_increment_plsql(i integer) RETURNS integer AS $$BEGINRETURN i + 1;END;
$$ LANGUAGE plpgsql;-- 删除函数
drop function if exists func_increment_plsql;-- 调用函数
CALL func_increment_plsql(1);