网络
虚拟私有云 VPC
弹性公网IP EIP
弹性负载均衡 ELB
NAT网关 NAT
云专线 DC
虚拟专用网络 VPN
云连接 CC
VPC终端节点 VPCEP
企业路由器 ER
企业交换机 ESW
全球加速 GA
企业连接 EC
云原生应用网络 ANC
安全与合规
安全技术与应用
Web应用防火墙 WAF
企业主机安全 HSS
云防火墙 CFW
安全云脑 SecMaster
DDoS防护 AAD
数据加密服务 DEW
数据库安全服务 DBSS
云堡垒机 CBH
数据安全中心 DSC
云证书管理服务 CCM
威胁检测服务 MTD
态势感知 SA
认证测试中心 CTC
边缘安全 EdgeSec
应用中间件
微服务引擎 CSE
分布式消息服务Kafka版
分布式消息服务RabbitMQ版
分布式消息服务RocketMQ版
API网关 APIG
分布式缓存服务 DCS
多活高可用服务 MAS
事件网格 EG
管理与监管
统一身份认证服务 IAM
消息通知服务 SMN
云监控服务 CES
应用运维管理 AOM
应用性能管理 APM
云日志服务 LTS
云审计服务 CTS
标签管理服务 TMS
配置审计 Config
应用身份管理服务 OneAccess
资源访问管理 RAM
组织 Organizations
资源编排服务 RFS
优化顾问 OA
IAM 身份中心
云运维中心 COC
资源治理中心 RGC
解决方案
高性能计算 HPC
SAP
混合云灾备
开天工业工作台 MIW
Haydn解决方案工厂
数字化诊断治理专家服务
云生态
云商店
合作伙伴中心
华为云开发者学堂
华为云慧通差旅
开发与运维
软件开发生产线 CodeArts
需求管理 CodeArts Req
流水线 CodeArts Pipeline
代码检查 CodeArts Check
编译构建 CodeArts Build
部署 CodeArts Deploy
测试计划 CodeArts TestPlan
制品仓库 CodeArts Artifact
移动应用测试 MobileAPPTest
CodeArts IDE Online
开源镜像站 Mirrors
性能测试 CodeArts PerfTest
应用管理与运维平台 ServiceStage
云应用引擎 CAE
开源治理服务 CodeArts Governance
华为云Astro轻应用
CodeArts IDE
Astro工作流 AstroFlow
代码托管 CodeArts Repo
漏洞管理服务 CodeArts Inspector
联接 CodeArtsLink
软件建模 CodeArts Modeling
Astro企业应用 AstroPro
CodeArts盘古助手
华为云Astro大屏应用
计算
弹性云服务器 ECS
Flexus云服务
裸金属服务器 BMS
云手机服务器 CPH
专属主机 DeH
弹性伸缩 AS
镜像服务 IMS
函数工作流 FunctionGraph
云耀云服务器(旧版)
VR云渲游平台 CVR
Huawei Cloud EulerOS
云化数据中心 CloudDC
网络
虚拟私有云 VPC
弹性公网IP EIP
弹性负载均衡 ELB
NAT网关 NAT
云专线 DC
虚拟专用网络 VPN
云连接 CC
VPC终端节点 VPCEP
企业路由器 ER
企业交换机 ESW
全球加速 GA
企业连接 EC
云原生应用网络 ANC
CDN与智能边缘
内容分发网络 CDN
智能边缘云 IEC
智能边缘平台 IEF
CloudPond云服务
安全与合规
安全技术与应用
Web应用防火墙 WAF
企业主机安全 HSS
云防火墙 CFW
安全云脑 SecMaster
DDoS防护 AAD
数据加密服务 DEW
数据库安全服务 DBSS
云堡垒机 CBH
数据安全中心 DSC
云证书管理服务 CCM
威胁检测服务 MTD
态势感知 SA
认证测试中心 CTC
边缘安全 EdgeSec
大数据
MapReduce服务 MRS
数据湖探索 DLI
表格存储服务 CloudTable
可信智能计算服务 TICS
推荐系统 RES
云搜索服务 CSS
数据可视化 DLV
数据接入服务 DIS
数据仓库服务 GaussDB(DWS)
数据治理中心 DataArts Studio
湖仓构建 LakeFormation
智能数据洞察 DataArts Insight
应用中间件
微服务引擎 CSE
分布式消息服务Kafka版
分布式消息服务RabbitMQ版
分布式消息服务RocketMQ版
API网关 APIG
分布式缓存服务 DCS
多活高可用服务 MAS
事件网格 EG
开天aPaaS
应用平台 AppStage
开天企业工作台 MSSE
开天集成工作台 MSSI
API中心 API Hub
云消息服务 KooMessage
交换数据空间 EDS
云地图服务 KooMap
云手机服务 KooPhone
组织成员账号 OrgID
云空间服务 KooDrive
管理与监管
统一身份认证服务 IAM
消息通知服务 SMN
云监控服务 CES
应用运维管理 AOM
应用性能管理 APM
云日志服务 LTS
云审计服务 CTS
标签管理服务 TMS
配置审计 Config
应用身份管理服务 OneAccess
资源访问管理 RAM
组织 Organizations
资源编排服务 RFS
优化顾问 OA
IAM 身份中心
云运维中心 COC
资源治理中心 RGC
区块链
区块链服务 BCS
数字资产链 DAC
华为云区块链引擎服务 HBS
解决方案
高性能计算 HPC
SAP
混合云灾备
开天工业工作台 MIW
Haydn解决方案工厂
数字化诊断治理专家服务
价格
成本优化最佳实践
专属云商业逻辑
云生态
云商店
合作伙伴中心
华为云开发者学堂
华为云慧通差旅
其他
管理控制台
消息中心
产品价格详情
系统权限
客户关联华为云合作伙伴须知
公共问题
宽限期保留期
奖励推广计划
活动
云服务信任体系能力说明
开发与运维
软件开发生产线 CodeArts
需求管理 CodeArts Req
流水线 CodeArts Pipeline
代码检查 CodeArts Check
编译构建 CodeArts Build
部署 CodeArts Deploy
测试计划 CodeArts TestPlan
制品仓库 CodeArts Artifact
移动应用测试 MobileAPPTest
CodeArts IDE Online
开源镜像站 Mirrors
性能测试 CodeArts PerfTest
应用管理与运维平台 ServiceStage
云应用引擎 CAE
开源治理服务 CodeArts Governance
华为云Astro轻应用
CodeArts IDE
Astro工作流 AstroFlow
代码托管 CodeArts Repo
漏洞管理服务 CodeArts Inspector
联接 CodeArtsLink
软件建模 CodeArts Modeling
Astro企业应用 AstroPro
CodeArts盘古助手
华为云Astro大屏应用
存储
对象存储服务 OBS
云硬盘 EVS
云备份 CBR
高性能弹性文件服务 SFS Turbo
弹性文件服务 SFS
存储容灾服务 SDRS
云硬盘备份 VBS
云服务器备份 CSBS
数据快递服务 DES
云存储网关 CSG
专属分布式存储服务 DSS
数据工坊 DWR
地图数据 MapDS
键值存储服务 KVS
容器
云容器引擎 CCE
云容器实例 CCI
容器镜像服务 SWR
云原生服务中心 OSC
应用服务网格 ASM
华为云UCS
数据库
云数据库 RDS
数据复制服务 DRS
文档数据库服务 DDS
分布式数据库中间件 DDM
云数据库 GaussDB
云数据库 GeminiDB
数据管理服务 DAS
数据库和应用迁移 UGO
云数据库 TaurusDB
人工智能
AI开发平台ModelArts
华为HiLens
图引擎服务 GES
图像识别 Image
文字识别 OCR
自然语言处理 NLP
内容审核 Moderation
图像搜索 ImageSearch
医疗智能体 EIHealth
企业级AI应用开发专业套件 ModelArts Pro
人脸识别服务 FRS
对话机器人服务 CBS
语音交互服务 SIS
人证核身服务 IVS
视频智能分析服务 VIAS
城市智能体
自动驾驶云服务 Octopus
盘古大模型 PanguLargeModels
IoT物联网
设备接入 IoTDA
全球SIM联接 GSL
IoT数据分析 IoTA
路网数字化服务 DRIS
IoT边缘 IoTEdge
设备发放 IoTDP
企业应用
域名注册服务 Domains
云解析服务 DNS
企业门户 EWP
ICP备案
商标注册
华为云WeLink
华为云会议 Meeting
隐私保护通话 PrivateNumber
语音通话 VoiceCall
消息&短信 MSGSMS
云管理网络
SD-WAN 云服务
边缘数据中心管理 EDCM
云桌面 Workspace
应用与数据集成平台 ROMA Connect
ROMA资产中心 ROMA Exchange
API全生命周期管理 ROMA API
政企自服务管理 ESM
视频
实时音视频 SparkRTC
视频直播 Live
视频点播 VOD
媒体处理 MPC
视频接入服务 VIS
数字内容生产线 MetaStudio
迁移
主机迁移服务 SMS
对象存储迁移服务 OMS
云数据迁移 CDM
迁移中心 MGC
专属云
专属计算集群 DCC
开发者工具
SDK开发指南
API签名指南
DevStar
华为云命令行工具服务 KooCLI
Huawei Cloud Toolkit
CodeArts API
云化转型
云架构中心
云采用框架
用户服务
账号中心
费用中心
成本中心
资源中心
企业管理
工单管理
客户运营能力
国际站常见问题
支持计划
专业服务
合作伙伴支持计划
我的凭证
华为云公共事业服务云平台
工业软件
工业数字模型驱动引擎
硬件开发工具链平台云服务
工业数据转换引擎云服务
本文导读

连接数据库

更新时间:2025-01-09 GMT+08:00
分享

在创建数据库连接之后,才能使用它来执行SQL语句操作数据。

函数原型

JDBC提供了三个方法,用于创建数据库连接。
  • DriverManager.getConnection(String url)
  • DriverManager.getConnection(String url, Properties info)
  • DriverManager.getConnection(String url, String user, String password)

参数

表1 数据库连接参数

参数

描述

url

使用opengaussjdbc.jar驱动包连接数据库时的连接描述符。

host为服务器名称或IPv4时,格式如下:

  • jdbc:gaussdb:(数据库名称缺省则与用户名一致)
  • jdbc:gaussdb:database
  • jdbc:gaussdb://host/database
  • jdbc:gaussdb://host:port/database
  • jdbc:gaussdb://host:port/database?param1=value1&param2=value2
  • jdbc:gaussdb://host1:port1,host2:port2/database?param1=value1&param2=value2

host为IPv6时,格式如下:

  • jdbc:gaussdb:(数据库名称缺省则与用户名一致)
  • jdbc:gaussdb:database
  • jdbc:gaussdb://host/database 或 jdbc:gaussdb://[host]/database
  • jdbc:gaussdb://[host]:port/database
  • jdbc:gaussdb://[host]:port/database?param1=value1&param2=value2
  • jdbc:gaussdb://[host1]:port1,[host2]:port2/database?param1=value1&param2=value2
说明:
  • database为要连接的数据库名称。
  • host为数据库服务器名称或IP地址,同时支持IPv4和IPv6。

    由于安全原因,数据库CN禁止集群内部其他节点无认证接入。如果要在集群内部访问CN,请将JDBC程序部署在CN所在机器,host使用"127.0.0.1"。否则可能会出现“FATAL: Forbid remote connection with trust method!”错误。

    建议业务系统单独部署在集群外部,否则可能会影响数据库运行性能。

    缺省情况下,连接服务器为localhost。

  • port为数据库服务器端口。

    缺省情况下,JDBC会尝试连接到5432端口的database。

  • 当host为IPv6且在url中指定port时,需要通过“[]”分隔IP,如:[IP]:port。
  • param为参数名称,即数据库连接属性。

    参数可以配置在URL中,以“?”开始配置,以“=”给参数赋值,以“&”作为不同参数的间隔。也可以采用info对象的属性方式进行配置,详情见示例

  • value为参数值,即数据库连接属性值。
  • 连接时需配置connectTimeout,socketTimeout,如果未配置,默认为0,即不会超时。在DN与客户端出现网络故障时,客户端一直未收到DN侧ACK确认报文,会启动超时重传机制,不断地进行重传。当超时时间达到系统默认的600s后才会报超时错误,这会导致RTO时间较高。
  • 建议使用JDBC标准接口建立连接时,确保url格式的合法性,不合法的url会导致异常,且异常中包含原始url字符串,可能造成敏感信息泄漏。

info

数据库连接属性(所有属性大小写敏感)。常用的属性如下:

  • PGDBNAME:String类型。表示数据库名称(URL中无需配置该参数,自动从URL中解析)。
  • PGHOST:String类型。主机IP地址,同时支持IPv4和IPv6。若配置多个CN,它们的IP和端口用“:”分隔,并作为整体以逗号分隔其他CN(URL中无需配置该参数,自动从URL中解析)。详情见示例
  • PGPORT:Integer类型。主机端口号。若配置多个CN,它们的端口号和IP用":"分割,并作为整体以逗号分隔其他CN(URL中无需配置该参数,自动从URL中解析)。详情见示例
  • user:String类型。表示创建连接的数据库用户。
  • password:String类型。表示数据库用户的密码。
  • enable_ce:String类型。其中enable_ce=1或者enable_ce=3都表示JDBC支持密态等值查询基本能力。
  • key_info:String类型。与enable_ce一起使用,在密态数据库中,用于设置访问外部密钥管理者的参数。
  • refreshClientEncryption:String类型。缺省值为NULL。其中refreshClientEncryption=1表示密态数据库支持客户端缓存刷新(默认值为1)。
  • loggerLevel:String类型。缺省值为NULL,与设置为INFO等效。目前支持4种级别:OFF、INFO、DEBUG、TRACE。设置为OFF关闭日志。设置为INFO、DEBUG和TRACE记录的日志信息详细程度不同。
  • loggerFile:String类型。用于指定日志输出路径(目录和文件名)。需要明确指定日志目录和文件名,若未指定目录则会在客户端运行程序目录下生成日志文件。若不配置或配置的路径不存在,则日志会默认通过流输出。此参数已废弃,不再生效,仅在开启连接监控功能时用于指定输出监控日志路径,如需将JDBC日志输出到指定路径,可通过 java.util.logging 属性文件或系统属性进行配置。
  • logger:String类型。表示JDBC Driver要使用的日志输出框架。JDBC Driver支持对接用户应用程序使用的日志输出框架。目前支持的第三方日志输出框架只有基于Slf4j-API的日志框架。具体使用方式,请参见6.2.9日志管理。
    1. 如果缺省或设置为JDK LOGGER,则JDBC Driver使用JDK LOGGER。
    2. 否则必须设置采用基于slf4j-API 第三方日志框架。
  • allowEncodingChanges:Boolean类型,缺省值为false。设置该参数值为true进行字符集类型更改,配合characterEncoding设置字符集,二者使用“&”分隔。例:allowEncodingChanges=true&characterEncoding=UTF8。详情参见characterEncoding属性描述。
  • characterEncoding:String类型,默认值为UTF8。需要配合allowEncodingChanges使用,allowEncodingChanges为false的情况下,characterEncoding仅允许设置为UTF8。allowEncodingChanges为true的情况下,characterEncoding取值范围为UTF8、GBK、LATIN1、GB18030、GB18030_2022、ZHS16GBK。
  • currentSchema:String类型。在search-path中指定要设置的schema。如果schema名包含除字母、数字、下划线之外的特殊字符,建议在schema名上加引号,注意加引号后schema名大小写敏感。如需配置多个schema,要用“,”进行分隔,包含特殊字符的schema也需要加引号处理。

    例如:currentSchema=schema_a、"schema-b"、"schema/c"。

  • loadBalanceHosts:Boolean类型。在默认模式下(禁用),顺序连接URL中指定的多个主机。如果启用,则使用洗牌算法从候选主机中随机选择一个主机建立连接。
  • autoBalance:String类型。
    1. 设置为true、balance或roundrobin表示开启JDBC负载均衡功能,将应用程序的多个连接均衡到数据库集群中的各个可用CN

      例如:jdbc:gaussdb://host1:port1,host2:port2/database?autoBalance=true

      JDBC将定期获取(周期刷新可使用参数refreshCNIpListTime配置,默认为10秒)整个集群可用CN列表(CN列表中获取的host是数据IP),比如获取到的列表为:host1:port1,host2:port2,host3:port3,host4:port4。

      host1和host2在autoBalance启用时,仅在首次连接作高可用用途,后续Driver将从host1、host2、host3和host4中依次选择可用的CN刷新可用CN列表,后续用户新建的connection将使用RoundRobin算法从host1、host2、host3和host4选取CN主机进行连接。

    2. 设置为priorityn表示开启JDBC优先级负载均衡功能,将应用程序的多个连接首先均衡到url上配置的前n个中可用的CN数据库节点。当url上配置前n个节点全部不可用时,连接会随机分配到数据库集群中其他可用CN数据库节点。n为数字,不小于0,且小于url上配置的CN数量。当parseCandidatesByDomain设置为true时,priorityn的优先级配置不生效,这种场景下的优先级使用priorityDomains参数配置。使用priorityn做负载均衡时,host不能使用IPv6。该策略在多进程建立连接场景下会出现负载不均衡。

      例如:jdbc:gaussdb://host1:port1,host2:port2,host3:port3,host4:port4/database?autoBalance=priority2

      JDBC将定期获取(周期按refreshCNIpListTime定义)整个集群可用CN列表,比如获取到的列表为:host1:port1,host2:port2,host3:port3,host4:port4,host5:port5,host6:port6。

      Driver将优先从host1、host2中做负载均衡,host1和host2全部不可用才从host3、host4、host5和host6中随机选择CN主机连接。

    3. 设置为shuffle表示开启JDBC随机负载均衡功能,将应用程序的多个连接随机均衡到数据库集群中的各个可用CN。

      例如:jdbc:gaussdb://host1:port1,host2:port2,host3:port3/database?autoBalance=shuffle

      JDBC将定期获取(周期刷新可使用参数refreshCNIpListTime配置,默认为10秒)整个集群的可用CN列表,比如获取到的列表为:host1:port1,host2:port2,host3:port3,host4:port4。

      host1:port1,host2:port2,host3:port3,仅在首次连接做高可用,后续连接将在刷新后的CN列表中,使用shuffle算法随机选用一个CN节点进行连接。

    4. 设置为specified表示开启JDBC负载均衡功能,并且只在用户url中指定的节点上建立连接。

      例如:jdbc:gaussdb://host1:port1,host2:port2,host3:port3,host4:port4/database?autoBalance=specified&priorityServers=2

      JDBC将识别用户指定host1、host2为用户指定主集群中建立连接的节点,host3、host4为备集群指定建立连接的节点。建立连接时,首先在host1、host2上均匀建立连接,全部故障时不会在集群剩余节点上建立连接。备节点升主后,在host3、host4上均匀建立连接,全部故障时不会在集群剩余节点上建立连接。

    5. 设置为shufflen表示开启JDBC在指定节点上优先随机负载均衡功能,将应用程序的多个连接首先随机均衡到url上配置的前n个中可用的CN数据库节点。当url上配置前n个节点全部不可用时,连接会随机分配到数据库集群中其他可用CN数据库节点。n为数字,不小于0,且小于等于url上配置的CN数量。

      当parseCandidatesByDomain设置为true时,shufflen的优先级配置不生效,这种场景下的优先级使用priorityDomains参数配置。使用shufflen做负载均衡时,host不能使用IPv6。该策略支持多进程建连场景下的指定优先节点负载均衡建立连接。

      例如:

      jdbc:gaussdb://ip1:port1,ip2:port2,ip3:port3,ip4:port4/database?autoBalance=shuffle2

      JDBC将定期获取(周期按refreshCNIpListTime定义)整个集群可用CN列表,比如获取到的列表为:

      ip1:port1,ip2:port2,ip3:port3,ip4:port4,ip5:port5,ip6:port6

      Driver将优先从ip1:port1,ip2:port2中做随机负载均衡,ip1:port1,ip2:port2全部不可用才从host3、host4、host5和host6中随机选择CN主机连接。

    6. 设置为false,不开启JDBC负载均衡功能和优先级负载均衡功能。默认为false。
      注意:
      1. 负载均衡是基于连接级别,不是基于事务级别。如果连接是长连接,并且连接上的负载不均衡,无法保证CN主机上的负载均衡。
      2. 负载均衡仅能在分布式场景下使用,集中式环境中不可使用。
      3. 如果在连接容灾集群时开启了负载均衡功能,那么查询请求会发送到主集群上,导致查询性能会受到影响。
      4. 在开启负载均衡时,URL中可以配置浮动IP或数据IP,如果配置为浮动IP,系统会根据浮动IP获取对应的数据IP,通过获取的数据IP做负载均衡。因此URL中配置浮动IP或数据IP时,都需要确保数据IP网络连接正常,否则负载均衡功能异常。
  • refreshCNIpListTime:Integer类型。获取CN列表的缓存有效时间。JDBC在建连时会检测数据库集群CN状态,在refreshCNIpListTime时间内可信。超过则状态失效,下次建连时再次获取可用CN的IP列表。默认为10秒。
  • hostRecheckSeconds:Integer类型。JDBC尝试连接主机后会保存主机状态:连接成功或连接失败。在hostRecheckSeconds时间内保持可信,超过则状态失效。缺省值是10秒。
  • ssl:Boolean类型。以SSL方式连接。

    ssl=true可支持NonValidatingFactory通道和使用证书的方式:

    1、NonValidatingFactory通道需要配置用户名和密码,同时将SSL设置为true。

    2、配置客户端证书、密钥、根证书,将SSL设置为true。

  • sslmode:String类型。SSL认证方式。取值范围为:disable、allow、prefer、require、verify-ca、verify-full。
    • disable:不使用SSL安全连接。
    • allow:如果数据库服务器要求使用,则可以使用SSL安全加密连接,但不验证数据库服务器的真实性。
    • prefer:如果数据库支持,那么首选使用SSL连接,但不验证数据库服务器的真实性。
    • require只尝试SSL连接,不会检查服务器证书是否由受信任的CA签发,且不会检查服务器主机名与证书中的主机名是否一致。
    • verify-ca只尝试SSL连接,并且验证服务器是否具有由可信任的证书机构签发的证书。
    • verify-full只尝试SSL连接,并且验证服务器是否具有由可信任的证书机构签发的证书,以及验证服务器主机名是否与证书中的一致。
  • sslgmcipher:String类型。指定国密TLS采用的加密算法套件。指定为ECC_SM4_SM3时表示支持国密单向/双向认证;指定为ECDHE_SM4_SM3时表示仅支持国密双向认证。
  • sslcert:String类型。提供证书文件的完整路径。客户端和服务端证书的类型为End Entity。
  • sslkey:String类型。提供密钥文件的完整路径。如果客户端密钥不是DER格式,使用时将客户端密钥转换为DER格式,生成方式请参见连接数据库(以SSL方式)章节。
  • sslenccert:String类型。提供国密TLS客户端加密证书的完整路径,证书类型为End Entity。
  • sslenckey:String类型。提供国密TLS加密密钥文件的完整路径。如果密钥不是DER格式,使用时将密钥转换为DER格式,生成方式请参见连接数据库(以SSL方式)
  • sslrootcert:String类型。SSL根证书的文件名。根证书的类型为CA。
  • sslpassword:String类型。提供给ConsoleCallbackHandler使用。
  • sslpasswordcallback:String类型。SSL密码提供者的类名。缺省值:com.huawei.gaussdb.jdbc.ssl.jdbc4.LibPQFactory.ConsoleCallbackHandler。
  • sslfactory:String类型。提供的值是SSLSocketFactory在建立SSL连接时用的类名。
  • sslprivatekeyfactory: String类型。提供的值是实现私钥解密方法的接口com.huawei.gaussdb.jdbc.ssl.PrivateKeyFactory的实现类的完整限定类名。如果不提供,首先尝试默认的jdk私钥解密算法,如果无法解密,则使用com.huawei.gaussdb.jdbc.ssl.BouncyCastlePrivateKeyFactory,用户需要提供bcpkix-jdk15on.jar包,版本建议:1.65以上。
  • sslfactoryarg:String类型。此值是sslfactory类的构造函数的可选参数(不推荐使用该参数)。
  • sslhostnameverifier:String类型。主机名验证程序的类名。接口实现javax.net.ssl.HostnameVerifier,默认使用com.huawei.gaussdb.jdbc.ssl.PGjdbcHostnameVerifier。
  • loginTimeout:Integer类型。指建立数据库连接的等待时间。超时时间单位为秒。当url配置多IP时,若获取连接花费的时间超过此值,则连接失败,不再尝试后续IP。缺省值为0,表示禁用。
  • connectTimeout:Integer类型。用于连接服务器操作的超时值。如果连接到服务器花费的时间超过此值,则连接断开。超时时间单位为秒,值为0时表示已禁用,timeout不生效。当url配置多IP时,表示连接单个IP的超时时间,缺省值为0。
  • socketTimeout:Integer类型。用于socket读取操作的超时值。如果从服务器读取所花费的时间超过此值,则连接关闭。超时时间单位为秒,值为0时表示已禁用,timeout不生效。缺省值为0。如果不配置该参数,在数据库进程异常情况下,会导致客户端出现长时间等待,建议根据业务可以接受的SQL执行时间进行配置。

    当JDBC侧触发超时且连接关闭时,其下发给数据库侧正在运行的业务会被强制终止。该能力受GUC参数check_disconnect_query控制,设置为on表示支持该能力,设置为off表示不支持该能力。

  • socketTimeoutInConnecting:Integer类型。用于控制建连阶段socket读取操作的超时值。如果建连时从服务器读取所花费的时间超过此值,则查找下一个节点建连。超时时间单位为秒,默认为5s。
  • statementTimeout:Integer类型。用于控制connection中statement执行时间的超时值。如果statement执行时间超过此值,则取消该statement执行。超时时间单位为毫秒,值为0表示已禁用,timeout不生效,缺省值为0。
  • cancelSignalTimeout:Integer类型。发送取消消息本身可能会阻塞,此属性用于控制取消命令的“connect超时”和“socket超时”。如果取消命令超过指定时间未响应,会中断该连接,减少占用客户端资源。超时时间单位为秒,默认值为10秒。
  • tcpKeepAlive:Boolean类型。启用或禁用TCP保活探测功能。默认为false。
  • logUnclosedConnections:Boolean类型,缺省值为false。客户端可能由于未调用Connection对象的close()方法而泄漏Connection对象。最终这些对象将被垃圾回收,并且调用finalize()方法。设置为true之后,如果调用者忽略了此操作,该方法将关闭Connection。
  • assumeMinServerVersion(废弃):String类型。该参数设置要连接的服务器版本。
  • ApplicationName:String类型。设置正在使用连接的应用程序名称。通过在CN上查询pgxc_stat_activity表可以看到正在连接的客户端信息,显示在application_name列。缺省值为GaussDB JDBC Driver。
  • connectionExtraInfo:Boolean类型。表示驱动是否上报当前驱动的部署路径、进程属主用户、url连接配置信息到数据库。

    取值范围:true或false,默认值为false。设置connectionExtraInfo为true,JDBC驱动会将当前驱动的部署路径、进程属主用户、url连接配置信息上报到数据库中,记录在connection_info参数里,同时可以在PG_STAT_ACTIVITY和PGXC_STAT_ACTIVITY中查询到。

  • autosave:String类型。共有3种:"always"、 "never"、"conservative"。如果查询失败,指定驱动程序应该执行的操作。在autosave=always模式下,JDBC驱动程序在每次查询之前设置一个保存点,并在失败时回滚到该保存点。在autosave=never模式(默认)下,无保存点。在autosave=conservative模式下,每次查询都会设置保存点,但是只会在“statement XXX无效”等情况下回滚并重试,缺省值为never。
  • protocolVersion:Integer类型。连接协议版本号,目前仅支持1和3。设置1时仅代表连接的是V1服务端。设置3时将采用MD5加密方式,需要同步修改数据库的加密方式,将GUC参数password_encryption_type设置为1,重启集群生效后需要创建用MD5方式加密口令的用户。同时修改gs_hba.conf,将客户端连接方式修改为MD5。用新建用户进行登录(因为设置该值后,只能使用低等级的加密方式(MD5),降低安全性,所以不推荐设置)。
    说明:

    MD5加密算法安全性低,存在安全风险,建议使用更安全的加密算法。

  • prepareThreshold:Integer类型。该值决定着PreparedStatement对象在执行多少次以后使用服务端已经准备好的statement。默认值是5,意味着在执行同一个PreparedStatement对象时,在第五次以及以上执行时不再向服务端发送parse消息对statement进行解析,而使用之前在服务端已经解析好的statement。
    说明:

    不建议通过JDBC,并且使用prepareStatement的方式执行涉及密码的语句(例如:CREATE USER user_name WITH PASSWORD '********';),原因是执行达到prepareThreshold指定次数时,数据库将SQL语句进行缓存,基于安全因素不会将密码进行缓存,该prepareStatement再次执行时会报错(Password must contain at least 8 characters.)。

  • preparedStatementCacheQueries:Integer类型。该参数确定了每个连接的cache缓存Statement对象生成query的最大个数。默认值为256,若Statement对象生成query个大于256则会将最近最少使用的query从缓存中丢弃。“0”表示禁用缓存。
  • preparedStatementCacheSizeMiB:Integer类型,该参数确定了每个连接的cache缓存Statement对象所生成query的最大值(以兆字节为单位),默认情况下是5。若缓存了超过5MB的query,则最近最少使用的查询缓存将被丢弃。“0”表示禁用缓存。
  • databaseMetadataCacheFields:Integer类型。默认值是65536。指定每个连接可缓存的最大字段的个数。“0”表示禁用缓存。
  • databaseMetadataCacheFieldsMiB:Integer类型。默认值是5。指定每个连接可缓存的字段的最大值,单位是MB。“0”表示禁用缓存。
  • stringtype:String类型。可选字段为:"unspecified"、"varchar"。设置通过setString()方法使用的PreparedStatement参数的类型,如果stringtype设置为VARCHAR(默认值),则这些参数将作为varchar参数发送给服务器。若stringtype设置为unspecified,则参数将作为untyped值发送到服务器,服务器将尝试推断适当的类型。
  • batchMode:String类型。用于确定是否使用batch模式连接。默认值为on,表示开启batch模式。设置batchMode=on执行成功的返回结果为[count, 0, 0...0],数组第一个元素为批量影响的总条数,设置batchMode=off执行成功的返回结果为[1, 1, 1...1],数组各元素对应单次修改的影响条数。注意:配置batchMode=on时,执行批量插入/批量修改操作,每一列的数据类型以第一条数据指定的类型为准,若数据类型混用可能会导致报错或者插入的数据异常。
  • fetchsize:Integer类型。用于设置数据库连接所创建statement的默认fetchsize。默认值为0,表示一次获取所有结果。与defaultRowFetchSize功能等价,如果同时设置,以fetchsize为准。
  • reWriteBatchedInserts:Boolean类型。缺省值为false。批量导入时,该参数设置为true,可将N条插入语句合并为一条:insert into TABLE_NAME values(values1, ..., valuesN), ..., (values1, ..., valuesN)。使用该参数时,需设置batchMode=off。
  • unknownLength:Integer类型。默认为Integer.MAX_VALUE。某些GaussDB类型(例如TEXT)没有明确定义的长度,当通过ResultSetMetaData.getColumnDisplaySize和ResultSetMetaData.getPrecision等函数返回关于这些类型的数据时,此参数指定未知长度类型的长度。
  • uppercaseAttributeName:String类型,只支持ORA兼容模式。默认值为false,表示元数据大小写以数据库侧guc参数uppercase_attribute_name配置为准;设置为upper、true时将元数据转为大写,主要适用场景为数据库中存储元数据全为小写,业务需要使用大写的元数据作为出参和入参的情况;设置为lower时将元数据转为小写。涉及到的接口请参见:java.sql.DatabaseMetaDatajava.sql.ResultSetMetaData
  • defaultRowFetchSize:Integer类型。确定一次fetch在ResultSet中读取的行数。限制每次访问数据库时读取的行数可以避免不必要的内存消耗,从而避免OutOfMemoryException。缺省值是0,意味着ResultSet中将一次获取所有行。本参数不允许设置为负值。
  • binaryTransfer:Boolean类型。使用二进制格式发送和接收数据,默认值为false。
  • binaryTransferEnable:String类型。启用二进制传输的类型列表,以逗号分隔。OID编号和名称二选一,例如binaryTransferEnable=INT4_ARRAY,INT8_ARRAY。比如:OID名称为BLOB,编号为88,可以进行如下配置:binaryTransferEnable=BLOB 或 binaryTransferEnable=88。
  • binaryTransferDisable:String类型。禁用二进制传输的类型列表,以逗号分隔。OID编号和名称二选一。覆盖binaryTransferEnable的设置。
  • blobMode:String类型。用于设置setBinaryStream方法绑定参数的数据类型,当该值为on时表示setBinaryStream绑定的数据类型为blob类型,为off时表示绑定的数据类型为bytea类型,默认为on。建议从ORA、MYSQL迁移的系统将该值设定为on,从PG迁移的系统设定为off。
  • socketFactory:String类型。用于创建与服务器socket连接的类的名称。该类必须实现接口“javax.net.SocketFactory”,并定义无参或单String参数的构造函数。
  • socketFactoryArg:String类型。此值是上面提供的socketFactory类的构造函数的可选参数,不推荐使用。
  • receiveBufferSize:Integer类型。该值用于设置连接流上的SO_RCVBUF。
  • sendBufferSize:Integer类型。该值用于设置连接流上的SO_SNDBUF。
  • preferQueryMode:String类型。共有4种:"extended"、"extendedForPrepared"、"extendedCacheEverything"和"simple"。用于指定执行查询的模式,默认值为extended。simple模式只发送Q消息,仅支持文本模式,不支持parse与bind;extended模式会使用parse、bind和execute消息;extendedForPrepared模式下只有Prepared Statement对象使用扩展查询,Statement对象只使用简单查询;extendedCacheEverything模式会缓存每个Statement对象所生成的query。
  • ApplicationType:String类型。共有2种:"not_perfect_sharding_type"、"perfect_sharding_type"。用于设置是否开启分布式写入和查询,默认值为"not_perfect_sharding_type"。not_perfect_sharding_type模式下开启分布式写入和查询,perfect_sharding_type模式下默认禁止分布式写入和查询,只有在sql文中加入/* multinode */ 才能执行分布式写入和查询。该项设置只有数据库处于gtm free场景的情况下才会有效。
  • priorityServers:Integer类型。此值用于指定url上配置的前n个节点作为主集群被优先连接。默认值为NULL。该值为数字,大于0且小于url上配置的CN数量。用于流式容灾场景。

    例如:jdbc:gaussdb://host1:port1,host2:port2,host3:port3,host4:port4,/database?priorityServers=2,即表示host1与host2为主集群节点,host3与host4为容灾集群节点。

  • usingEip:Boolean类型。此值用于控制是否使用弹性公网IP做负载均衡。默认值为true,表示使用弹性公网IP做负载均衡,false表示使用数据IP做负载均衡。当usingEip=true或者不配置时,url中的host需使用弹性公网IP,usingEip=false时,url中的host需使用数据IP,否则会导致priorityn和shufflen负载均衡策略失效。
  • traceInterfaceClass:String类型。默认值为NULL,用于获取traceId的实现类。值是实现获取traceId方法的接口com.huawei.gaussdb.jdbc.log.Tracer的实现类的完整限定类名。
  • use_boolean:Boolean类型。用于设置extended模式下setBoolean方法绑定的oid类型,默认为false,绑定int2类型。设置为true则绑定boolean类型。
  • allowReadOnly:Boolean类型。用于设置是否允许连接开启只读模式,默认为true,允许设置只读模式。设置为false则禁用只读模式,此时调用connection.setReadOnly(true)不生效,仍可以修改数据。
  • TLSCiphersSupperted:String类型。用于设置支持的TLS加密套件,默认为TLS_DHE_RSA_WITH_AES_128_GCM_SHA256,TLS_DHE_RSA_WITH_AES_256_GCM_SHA384,TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384。
  • stripTrailingZeros:Boolean类型。默认值为false,设置为true则去除numeric类型后的0,仅对ResultSet.getObject(int columnIndex)生效。
  • enableTimeZone:Boolean类型。默认值为true,用于指定是否启用服务端时区设置,true表示获取JVM时区指定数据库时区,false表示使用数据库时区。
  • enableStandbyRead:Boolean类型。默认值为false,用于指定是否开启备机读模式,true表示启用,false表示禁用。
  • compatibilityTags:String类型。默认为NULL,用于将驱动的部分特性恢复到早期版本,以确保前向兼容。可配置一个或多个tag,每个tag代表开启对应的前向兼容性特性,不同tag之间用“,”隔开。一般不建议使用该参数,除非有明确的前向兼容问题。目前支持的tag如下:

    typeMapInitNull:使用该tag后,兼容驱动早期版本的行为,java.sql.Connection中typeMap的初始值为NULL,如果不使用该tag,初始值为空Map。

  • parseCandidatesByDomain:Boolean类型。默认值false,用于指定是否根据域名获得候选节点。true表示启用,false表示禁用。开启后需要将url中的host信息配置成域名+端口的形式,驱动会基于域名获得IP,生成备节点集合,并可以配合autoBalance参数做负载均衡。
  • primaryDomains:Integer类型。用于指定url上配置的前n个域名作为主集群被优先连接。默认为0,表示关闭。需要将parseCandidatesByDomain参数设置为true时才能生效,大于0表示开启,且取值要小于url上配置的域名数量。将url中的域名拆分成两个分组,前一个分组为主集群,后一个分组为备集群。发生主备切换后,两个分组交换位置,前一个分组为主集群,后一个分组为备集群。适用于流式容灾和Dorado双集群场景。

    例如:jdbc:gaussdb://domain1:port1,domain2:port2,domain3:port3,domain4:port4/database?parseCandidatesByDomain=true&primaryDomains=2,即表示domain1和domain2对应主集群,优先连domain1和domain2对应的IP。如果发生主备切换,将domain3和domain4标记为主集群,优先对domain3和domain4建连。

  • priorityDomains:Integer类型。用于指定url上配置的前n个域名作为优先连接的域名。默认为0,表示关闭,需要将parseCandidatesByDomain参数设置为true时才能生效,大于0表示开启,且取值要小于url上配置的域名数量,如果配置了primaryDomains,则需要小于primaryDomains配置的数值。

    例如:jdbc:gaussdb://domain1:port1,domain2:port2,domain3:port3,domain4:port4/database?parseCandidatesByDomain=true&primaryDomains=2&priorityDomains=1,即表示domain1和domain2对应主集群,但是优先连domain1对应的IP,domain2是备用域名,只有domain1不可连后才尝试连domain2。如果发生主备切换,将domain3和domain4标记成主集群,但是优先连domain3对应的IP,domain3不可以连后才尝试连domain4对应的IP。

  • refreshDomainResolveTime:Integer类型。默认为10,单位是秒,最小值为1,最大值为2147483647。代表域名解析结果的刷新周期,需要将parseCandidatesByDomain参数设置为true时才能生效,生效后会将url中涉及的域名解析刷新时间设置为指定的数值,并在异步线程中定时更新域名解析结果。驱动仅通过应用所在环境的DNS服务获取域名解析结果,为保障域名绑定的变更被驱动及时感知,需要应用所在环境的DNS服务保障域名绑定关系变更后能够及时生效。
  • oracleCompatible:String类型。默认为false。用户控制驱动接口的ORA兼容特性。有以下几种取值:
    1. 设置为true或on:表示开启驱动侧所有的ORA兼容特性。
    2. 设置为false或off:表示关闭驱动侧所有的ORA兼容特性。
    3. 设置为"tag1,tag2,tag3":配置一个或多个tag,tag之间用“,”隔开,表示开启驱动侧部分的ORA兼容特性,每个tag对应一个ORA兼容特性。

      当前支持的tag有:

      • getProcedureColumns:DatabaseMetaData#getProcedureColumns接口的行为兼容ORA行为。
      • getCallableStatementResults:开启后,调用CallableStatement的getLong、getInt、getShort、getByte四个接口时与ORA模式数据库保持一致。在注册出参类型为java.sql.Types#NUMERIC时,调用CallableStatement的getLong、getInt、getShort、getByte接口,能够正常接收out的值,只有out数值超过java数值数据类型取值范围会提示SQLException异常。
      • batchInsertAffectedRows:reWriteBatchedInserts开启后,执行批量插入接口Statement#executeBatch的返回结果兼容ORA行为。
      • setDateTime:开启后,PBE模式下绑定Date、Time、Timestamp类型参数时,指定具体oid下发至内核。
  • printSqlInLog:Boolean类型。默认值为true,用于指定异常信息中或日志中是否输出sql语句,true表示启用,false表示禁用。
  • useGsClobBlobClass:Boolean类型。默认为false,表示关闭。
    • 设置为true开启后,使用java.sql.ResultSet#getObject接口获取clob字段时,会返回PGClob类型的对象。获取blob字段时会返回PGBlob类型的对象。通过元数据接口java.sql.ResultSetMetaData#getColumnClassName获取clob字段的类型名称会返回java.sql.Clob,获取blob字段的类型名称时会返回java.sql.Blob。
    • 设置为false关闭后,使用java.sql.ResultSet#getObject接口获取clob字段时,会返回PGClob类型的对象。获取blob字段时会返回byte[]类型的对象。通过元数据接口java.sql.ResultSetMetaData#getColumnClassName获取clob字段的类型名称会返回java.sql.CLOB,获取blob字段的类型名称时会返回java.sql.BLOB。
  • sessionType:String类型。指定当前会话的类型,根据用户实际取值生成执行计划。默认值为normal,取值为范围:singleNode、globalReadOnly、normal。
    • normal:默认值,表示普通会话,根据数据库原有逻辑执行计划。
    • singleNode:表示会话为单节点会话,会话的读写操作支持下推。单节点会话模式是通过CN向指定的目标DN进行1对1的会话模式。需与参数execTargetNode同时使用,设置参数execTargetNode为目标DN节点名称,JDBC会优先连接目标DN节点对应的本地CN节点。
    • globalReadOnly:表示会话为跨节点只读会话模式。该模式下,会正常生成分布式计划,但禁止分布式写操作。
  • execTargetNode:String类型。需与参数sessionType同时使用,参数sessionType设置为singleNode模式时生效。表示单节点会话模式下对应的DN节点,取值为当前集群内的所有DN节点名称。若参数sessionType设置为singleNode模式,未指定execTargetNode时(默认值为NULL),效果与sessionType设置为normal一致。
  • executeUpdateQueryable:Boolean类型。默认值为false,用于指定executeUpdate方法是否开启执行DQL语句,true表示启用,false表示禁用。开启后,executeUpdate方法执行DQL语句的返回值为-1,能够得到结果集。不推荐开启此参数。
  • dbMonitor:Boolean类型。默认值为false,用于指定JDBC是否开启连接监控功能。true表示启用,false表示禁用。
    • 连接监控功能支持监控JDBC端以下指标:应用开启连接的次数、关闭连接的次数、连接异常断开的次数,数据库访问量,客户端机器CPU的使用率、内存的使用率、上下行传输速率,应用端到数据库链路之间的网络时延、抖动、丢包率。
    • 将dbMonitor设置为true、loggerLevel设置为debug、loggerFile设置为filePath,可将客户端的连接监控输出到日志文件filePath中,具体示例见示例4 数据库连接监控功能使用示例
  • enableStreamingQuery:Boolean类型。默认值为false,用于控制是否开启流式读功能。true表示开启,false表示关闭。将该参数值设置为true,同时使用statement.setFetchSize(Integer.MIN_VALUE)或者statement.enableStreamingResults(),表示开启流式读功能。

    流式读:读取数据时,一次获取全部,发送到客户端socket缓冲区中,缓冲区占满则暂停,有空余则继续向缓冲区中发送数据,同时JVM逐行从缓冲区中读取数据。流式读的优势是处理结果快,不会造成JVM内存溢出,劣势是只能向后遍历,数据处理完毕之前或者statement关闭之前,当前连接不能执行其他操作,具体示例见示例部分的示例2。

  • yearIsDateType:Boolean类型。默认值为true,表示开启。
    • 设置为true开启后,使用java.sql.ResultSet#getObject接口获取YEAR数据类型字段时会返回DATE类型的对象,使用java.sql.ResultSet#getString接口获取数据时会返回yyyy-mm-dd格式的日期字符串,使用java.sql.ResultSet#getInt/getLong/getShort接口获取数据会返回年份数值。
    • 设置为false关闭后,使用java.sql.ResultSet#getObject接口获取YEAR数据类型字段时会返回INTEGER类型的对象,使用java.sql.ResultSet#getString接口获取数据时返回年份的字符串,使用java.sql.ResultSet#getInt/getLong/getShort接口获取数据会返回年份数值。
  • enableObjectTypeConv:Boolean类型,控制是否允许ResultSet接口中getObject(int, Class<?>)方法支持兼容类型转换,取值为true/false,设置为true则允许兼容类型转换,默认为false,表示关闭。当前已支持Integer与Long、Double、BigDecimal类型互转,Clob与String类型互转。
  • disasterToleranceCluster:Boolean类型,默认为false,表示在开启负载均衡功能的场景下且JDBC连接数据库的url中只配置容灾集群节点时,判断负载均衡连接到主集群或连接到容灾集群。true表示开启,会在容灾集群节点进行负载均衡;false表示关闭,会在主集群节点间进行负载均衡。该参数不可与priorityServers参数共同使用。
  • pgCompatible:Boolean类型,用于控制JDBC对SQL语法解析方式是否兼容PostgreSQL,默认为false,表示SQL语句解析方式采用默认行为(不兼容PostgreSQL)。设置为true后语法解析兼容PostgreSQL,支持一个statement中包含多条SQL,并使用分号进行分隔的使用场景,在开启后不支持执行语句中带有分号的SQL。
  • setFloat:Boolean类型,表示调用setFloat或者setObject指定类型为float时,传递给内核的Oid是否为float4的Oid。true表示传递给内核的Oid为float4,false表示传递给内核的Oid为float8,默认为false。

user

数据库用户。

password

数据库用户的密码。

说明:

uppercaseAttributeName参数开启后,如果数据库中有小写、大写和大小写混合的元数据,则只能查询出小写部分的元数据,并以大写的形式输出。使用前请务必确认元数据的存储是否全为小写以避免数据出错。

JDBC驱动支持数据库DDL操作修改表结构后正常执行。

jdbc.version_num仅用在建连时向内核传递JDBC版本号,不做其他用途,请勿使用。jdbc.version_num从503.1版本开始支持(此前使用jdbc.version参数完成该功能,后续废弃),jdbc.version_num使用规范如下:

jdbc.version_num

版本

范围

使用规则

内核判断

备注

502xx

505.2

50200-50299

版本内必须先使用最小可用值

版本号>=502xx(最新设置值)

相关兼容性改动必须同步合入更高版本分支

501xx

505.1

50100-50199

版本内必须先使用最小可用值

版本号>=501xx(最新设置值)

相关兼容性改动必须同步合入更高版本分支

500xx

505.0

50000-50099

版本内必须先使用最小可用值

版本号>=500xx(最新设置值)

相关兼容性改动必须同步合入更高版本分支

301xx

503.1

30100-30199

版本内必须先使用最小可用值

版本号>=301xx(最新设置值)

相关兼容性改动必须同步合入更高版本分支

示例

示例1:连接数据库

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
// 以下用例以gaussdbjdbc.jar为例。
// 以下代码将获取数据库连接操作封装为一个接口,可通过给定用户名和密码来连接数据库。
public static Connection getConnect(String username, String passwd)
    {
        // 驱动类。
        String driver = "com.huawei.gaussdb.jdbc.Driver";
        // 数据库连接描述符。
        String sourceURL = "jdbc:gaussdb://$ip:$port/database";
        Connection conn = null;
        
        try
        {
            // 加载驱动。
            Class.forName(driver);
        }
        catch( Exception e )
        {
            e.printStackTrace();
            return null;
        }
        
        try
        {
             // 创建连接。
            conn = DriverManager.getConnection(sourceURL, username, passwd);
            System.out.println("Connection succeed!");
        }
        catch(Exception e)
        {
            e.printStackTrace();
            return null;
        }
        
        return conn;
    }

示例2:使用Properties对象作为参数建立连接

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
// 以下代码将使用Properties对象作为参数建立连接。
public static Connection getConnectUseProp(String username, String passwd)
    {
        // 驱动类。
        String driver = "com.huawei.gaussdb.jdbc.Driver";
        // 数据库连接描述符。
        String sourceURL = "jdbc:gaussdb://$ip:$port/database?autoBalance=true";
        Connection conn = null;
        Properties info = new Properties();
        
        try
        {
            // 加载驱动。
            Class.forName(driver);
        }
        catch( Exception e )
        {
            e.printStackTrace();
            return null;
        }
        
        try
        {
             info.setProperty("user", username);
             info.setProperty("password", passwd);
             // 创建连接。
             conn = DriverManager.getConnection(sourceURL, info);
             System.out.println("Connection succeed!");
        }
        catch(Exception e)
        {
            e.printStackTrace();
            return null;
        }
        
        return conn;
    }

常用参数详细请参见JDBC常用参数参考

示例3:使用流式读功能

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
// 认证用的用户名和密码直接写到代码中有很大的安全风险,建议在配置文件或者环境变量中存放(密码应密文存放,使用时解密),确保安全。
// 本示例以用户名和密码保存在环境变量中为例,运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
// 建立连接。
public static Connection getConnection(String username, String passwd) {
    String driver = "com.huawei.gaussdb.jdbc.Driver";
    String sourceURL = "jdbc:gaussdb://$ip:$port/database?enableStreamingQuery=true";
    Connection conn = null;
    try {
        // 加载驱动。
        Class.forName(driver);
    } catch (Exception e) {
        e.printStackTrace();
        return null;
    }
    try {
        // 创建连接。
        conn = DriverManager.getConnection(sourceURL, username, passwd);
        System.out.println("Connection succeed!");
    } catch (Exception e) {
        e.printStackTrace();
        return null;
    }
    return conn;
}

// 执行普通SQL语句,创建t_user表。
public static void CreateTable(Connection conn) {
    Statement stmt = null;
    try {
        stmt = conn.createStatement();

        // 执行普通SQL语句。
        stmt.executeUpdate("DROP TABLE IF EXISTS t_user");
        stmt.executeUpdate("CREATE TABLE t_user(id int, name VARCHAR(20));");
        stmt.close();
    } catch (SQLException e) {
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        }
        e.printStackTrace();
    }
}

// 执行预处理语句,批量插入数据。
public static void BatchInsertData(Connection conn) {
    PreparedStatement pst = null;

    try {
        // 生成预处理语句。
        pst = conn.prepareStatement("INSERT INTO t_user VALUES (?,?)");
        for (int i = 0; i < 20; i++) {
            // 添加参数。
            pst.setInt(1, i + 1);
            pst.setString(2, "name " + (i + 1));
            pst.addBatch();
        }
        // 执行批处理。
        pst.executeBatch();
        pst.close();
    } catch (SQLException e) {
        if (pst != null) {
            try {
                pst.close();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        }
        e.printStackTrace();
    }
}

// 开启流式读,查询t_user表中内容。
public static void StreamingQuery(Connection conn) {
    PreparedStatement pst = null;
    ResultSet resultSet = null;

    try {
        // 查询表t_user中的所有值。
        pst = conn.prepareStatement("SELECT * FROM t_user");
        pst.setFetchSize(Integer.MIN_VALUE);// ((PgStatement)statement).enableStreamingResults(); 两者作用一致。
        resultSet = pst.executeQuery();
        while (resultSet.next()) {
            System.out.println(resultSet.getInt(1));
        }
    } catch (SQLException e) {
        throw new RuntimeException(e);
    } finally {
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }

        if (pst != null) {
            try {
                pst.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }
}

public static void main(String[] args) throws Exception {
    String userName = System.getenv("EXAMPLE_USERNAME_ENV");
    String password = System.getenv("EXAMPLE_PASSWORD_ENV");
    Connection conn = getConnection(userName , password);

    CreateTable(conn);

    BatchInsertData(conn);

    StreamingQuery(conn);

    // 关闭数据库连接。
    try {
        conn.close();
    } catch (SQLException e) {
        e.printStackTrace();
    }
}
须知:

使用流式读功能时,结果集使用完之后,需要执行resultSet.close()或者statement.close()操作,否则当前连接将不可用。

提示

您即将访问非华为云网站,请注意账号财产安全

文档反馈

文档反馈

意见反馈

0/500

标记内容

同时提交标记内容