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

PostgreSQL与Greenplum数据库的编程语言连接

web 2025/9/7 5:58:52

编程语言连接数据库

目前数据库一般支持HA的连接，即一个Coordinator内的一个节点异常后会链接到另外的一个节点，不会影响业务的正常运行。在JDBC配置时需要采用 高可用链接字符串(Connection URL/DSN) 的方式连接。适用于不同的编程语言中使用，URL例如:

postgres://username1:password1@CoordinatorIP:CoordinatorPort,CoordinatorIP:CoordinatorPort/database?sslmode=disable

username1: Coordinator1数据库用户名

password1: Coordinator1数据库密码

CoordinatorIP: Coordinator1数据库IP

CoordinatorPort: Coordinator1数据库端口

database: 数据库名

sslmode: 表示是否启用 SSL 连接。

URL 高级连接参数

插入数据时的参数

如果在批量加载数据时需要添加以下的参数，为了在加载数据时按照batchSize进行批量写入，可以添加以下参数：

preferQueryMode=extendedForPrepared&reWriteBatchedInserts=true

https://doris.apache.org/zh-CN/docs/3.0/data-operate/import/group-commit-manual

preferQueryMode: 指定使用哪种模式来执行对数据库的查询：simple 表示（Q执行，不解析，不绑定，仅文本模式），extended 表示始终使用绑定 / 执行消息，extendedForPrepared 表示仅对预编译语句使用 extended 模式，endedCacheEverything 表示使用扩展协议并尝试在查询缓存中缓存每一条语句（包括 Statement.execute (String sql)）。取值为 extended | extendedForPrepared | extendedCacheEverything | simple 。

reWriteBatchedInserts: 这会将批量插入语句从 insert into foo (col1, col2, col3) values (1, 2, 3) 改为 insert into foo (col1, col2, col3) values (1, 2, 3), (4, 5, 6)，这样能提升 2 - 3 倍的性能。

在高并发读取时的参数

preparedStatementCacheQueries=512&defaultRowFetchSize=500&prepareThreshold=10

preparedStatementCacheQueries：一个会话中最大能缓存的PreparedStatement数量，默认值256，在高并发读取时可以适当调整为512.

defaultRowFetchSize：每次以游标的形式从数据库中获取的行数，默认值0不限制，可以适当调整为500，每次获取500行。

prepareThreshold：确定在切换到使用服务器端预编译语句之前，PreparedStatement所需的执行次数。默认值为 5，这意味着在同一个PreparedStatement对象执行第 5 次时开始使用服务器端预编译语句。

PostgreSQL JDBC 官方参数详解

JAVA 链接案例

驱动下载

建议选择使用与 PostgreSQL 与 Greenplum 兼容的驱动。

  • PostgreSQL 官方驱动

  • Greenplum 官方驱动

  • PostgreSQL® Extensions to the JDBC API

连接案例

  • Java JDBC 操作代码示例

Python 链接案例

驱动下载

  • Python 官方驱动
# 轻量版驱动
pip install psycopg2-binary# 本地编译
pip install psycopg2

链接案例


import psycopg2#  1. 连接数据库（替换为你的实际参数）
conn = psycopg2.connect(host="localhost",database="testdb",user="postgres",password="yourpassword"
)# 2. 创建游标
cur = conn.cursor()# 3. 创建表（如果不存在）
cur.execute("""CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY,name VARCHAR(100),email VARCHAR(100) UNIQUE)
""")# 4. 插入一条数据
cur.execute("INSERT INTO users (name, email) VALUES (%s, %s)",("Alice", "alice@example.com")
)# 5. 查询数据
cur.execute("SELECT * FROM users")
rows = cur.fetchall()
for row in rows:print(f"ID: {row[0]}, Name: {row[1]}, Email: {row[2]}")# 6. 关闭连接
conn.commit()  # 提交事务
cur.close()
conn.close()

Go 链接案例

驱动下载

pgx 是一个用于 PostgreSQL 的纯 Go 语言驱动程序和工具包。

链接案例

package mainimport ("context""fmt""os""github.com/jackc/pgx/v5"
)func main() {// urlExample := "postgres://username:password@localhost:5432/database_name"conn, err := pgx.Connect(context.Background(), os.Getenv("DATABASE_URL"))if err != nil {fmt.Fprintf(os.Stderr, "Unable to connect to database: %v\n", err)os.Exit(1)}defer conn.Close(context.Background())var name stringvar weight int64err = conn.QueryRow(context.Background(), "select name, weight from widgets where id=$1", 42).Scan(&name, &weight)if err != nil {fmt.Fprintf(os.Stderr, "QueryRow failed: %v\n", err)os.Exit(1)}fmt.Println(name, weight)
}

如果对与兼容性要求高，性能不是很高的场景可以使用pg 的连接驱动。

C 链接案例

建议使用 psqlODBC 的驱动连接 PostgreSQL 。下载并配置驱动的方式如下：

驱动下载

sudo yum install -y unixODBC unixODBC-devel postgresql-odbc

配置驱动

在etc/下创建件odbcinst.ini和odbc.ini配置文件内容如下:

# cat /etc/odbcinst.ini
[PostgreSQL]
Description = ODBC for PostgreSQL
Driver      = /usr/lib/psqlodbcw.so
Setup       = /usr/lib/libodbcpsqlS.so
Driver64    = /usr/lib64/psqlodbcw.so
Setup64     = /usr/lib64/libodbcpsqlS.so
FileUsage = 1# cat /etc/odbc.ini
[pg]
Description = Test to pg
Driver = PostgreSQL
Database = test
# Servername 集群的 Master,Standby的IP地址
Servername = <Master,Standby>
UserName = username
Password = password
# Master,Standby 的集群端口
Port = <Master Port,Standby Port>
ReadOnly = 0

C 链接代码

编写odbc_test.c代码，案例如下：

#include <stdio.h>
#include <sql.h>
#include <sqlext.h>void check_error(SQLRETURN ret, SQLHANDLE handle, SQLSMALLINT type) {if (!SQL_SUCCEEDED(ret)) {SQLCHAR sqlstate[6], message[256];SQLSMALLINT len;SQLError(handle, type, sqlstate, NULL, message, sizeof(message), &len);fprintf(stderr, "ERROR: %s (SQLSTATE %s)\n", message, sqlstate);exit(1);}
}int main() {SQLHENV env;SQLHDBC dbc;SQLHSTMT stmt;SQLRETURN ret;SQLCHAR connstr[] = "DSN=testdb";// 1. 初始化环境SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);// 2. 建立连接SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);ret = SQLDriverConnect(dbc, NULL, connstr, SQL_NTS, NULL, 0, NULL, SQL_DRIVER_COMPLETE);check_error(ret, dbc, SQL_HANDLE_DBC);// 3. 创建表SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt);SQLExecDirect(stmt, "CREATE TABLE IF NOT EXISTS users(id SERIAL PRIMARY KEY, name VARCHAR(50))", SQL_NTS);printf("Table created\n");// 4. 插入数据SQLExecDirect(stmt, "INSERT INTO users(name) VALUES ('CentOS User')", SQL_NTS);printf("Data inserted\n");// 5. 查询数据SQLExecDirect(stmt, "SELECT * FROM users", SQL_NTS);SQLCHAR name[50];while (SQLFetch(stmt) == SQL_SUCCESS) {SQLGetData(stmt, 2, SQL_C_CHAR, name, sizeof(name), NULL);printf("User: %s\n", name);}// 6. 清理资源SQLFreeHandle(SQL_HANDLE_STMT, stmt);SQLDisconnect(dbc);SQLFreeHandle(SQL_HANDLE_DBC, dbc);SQLFreeHandle(SQL_HANDLE_ENV, env);return 0;
}

C# 连接案例

驱动下载

sudo rpm -Uvh https://packages.microsoft.com/config/centos/7/packages-microsoft-prod.rpm
sudo yum install -y dotnet-sdk-6.0

链接案例

创建项目并编写代码

dotnet new console -n PgOdbcDemo
cd PgOdbcDemo

编辑 Program.cs 文件

using System;
using System.Data.Odbc;class Program
{static void Main(){// 使用DSN或直接连接字符串string connStr = "Dsn=testdb;";using (var conn = new OdbcConnection(connStr)){conn.Open();Console.WriteLine("Connected to PostgreSQL via ODBC");// 查询版本var cmd = new OdbcCommand("SELECT version(), current_user", conn);using (var reader = cmd.ExecuteReader()){while (reader.Read()){Console.WriteLine($"Version: {reader[0]}");Console.WriteLine($"Current User: {reader[1]}");}}}}
}

运行项目

dotnet run

Ruby 连接案例

驱动下载

推荐使用ruby-pg作为Ruby的PostgreSQL驱动。

要求Ruby 2.7 及以上版本。
PostgreSQL 10 及以上版本。

yum install -y gemgem install pg -- --with-pg-config=<path to pg_config>bundle config build.pg --with-pg-config=<path to pg_config>

链接案例

  #!/usr/bin/env rubyrequire 'pg'# Output a table of current connections to the DBconn = PG.connect( dbname: 'sales' )conn.exec( "SELECT * FROM pg_stat_activity" ) do |result|puts "     PID | User             | Query"result.each do |row|puts " %7d | %-16s | %s " %row.values_at('pid', 'usename', 'query')endend

Rust 连接案例

驱动下载

推荐使用rust-postgres 作为数据库的连接驱动。

链接案例

use tokio_postgres::{NoTls, Error};async fn main() -> Result<(), Error> {let conn_str = "host=localhost user=your_username password=your_password dbname=your_dbname";let (client, connection) = tokio_postgres::connect(conn_str, NoTls).await?;tokio::spawn(async move {if let Err(e) = connection.await {eprintln!("连接池错误: {}", e);}});println!("连接成功！");let stmt = client.prepare("SELECT version();").await?;let rows = client.query(&stmt, &[]).await?;for row in rows {let version: String = row.get(0);println!("PostgreSQL版本: {}", version);}Ok(())
}

NodeJS 连接案例

驱动下载

推荐使用postgres作为链接驱动。

$ npm install postgres

链接案例

推荐使用 Async/Await 的方法。

const { Client } = require('pg');async function main() {const client = new Client({host: 'localhost',user: 'postgres',password: 'yourpassword',database: 'testdb',});try {await client.connect();await client.query('BEGIN');const insertRes = await client.query('INSERT INTO users (name) VALUES ($1) RETURNING id',['Bob']);await client.query('COMMIT');console.log('Inserted ID:', insertRes.rows[0].id);} catch (err) {await client.query('ROLLBACK');console.error('Error:', err);} finally {await client.end();}
}main();

PHP 连接案例

驱动下载

驱动建议安装7.4 及以上的版本。

# 安装驱动
sudo yum install php-pgsql# 验证安装的驱动
php -m | grep pgsql

链接案例

<?php
$host = 'localhost';
$dbname = 'testdb';
$user = 'postgres';
$password = 'yourpassword';try {$pdo = new PDO("pgsql:host=$host;dbname=$dbname", $user, $password, [PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,PDO::ATTR_PERSISTENT => true,  PDO::ATTR_TIMEOUT => 5         ]);$pdo->exec("CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY,name VARCHAR(100),email VARCHAR(100) UNIQUE)");$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (?, ?)");$stmt->execute(['Alice', 'alice@example.com']);echo "Inserted ID: " . $pdo->lastInsertId() . "\n";$stmt = $pdo->query("SELECT * FROM users");while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {echo "ID: {$row['id']}, Name: {$row['name']}\n";}} catch (PDOException $e) {die("Error: " . $e->getMessage());
}
?>

Perl 连接案例

驱动下载

建议使用Perl5 的5.40.0 及更高版本

# Debian/Ubuntu 安装方式
sudo apt-get install libdbd-pg-perl# CentOS/RHEL 安装方式
sudo yum install perl-DBD-Pg

链接案例

#!/usr/bin/perl
use strict;
use warnings;
use DBI;my $dsn = "DBI:Pg:dbname=testdb;host=localhost;port=5432";
my $user = "postgres";
my $password = "yourpassword";my $dbh = DBI->connect($dsn, $user, $password, {RaiseError => 1,       # 自动报错AutoCommit => 0,       # 关闭自动提交（启用事务）pg_server_prepare => 1 # 启用服务器端预处理
}) or die $DBI::errstr;$dbh->do(<<'SQL');
CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY,name VARCHAR(100),email VARCHAR(100) UNIQUE
)
SQLmy $insert = $dbh->prepare("INSERT INTO users (name, email) VALUES (?, ?) RETURNING id"
);
$insert->execute('Alice', 'alice@example.com');
my $new_id = $insert->fetchrow_arrayref->[0];
print "Inserted ID: $new_id\n";my $sth = $dbh->prepare("SELECT * FROM users");
$sth->execute();
while (my $row = $sth->fetchrow_hashref) {print "ID: $row->{id}, Name: $row->{name}\n";
}$dbh->commit;$sth->finish;
$dbh->disconnect;

Excel 链接数据库

驱动下载

建议从psqlODBC 驱动安装包下载ODBC 驱动。

链接案例

链接案例请参考使用 Excel 访问 PostgreSQL

http://www.xdnf.cn/news/20427.html

相关文章：

  • 深入理解 RequestContextHolder、ThreadLocal 与 RequestContextFilter
  • Spring 基于注解的自动化事务
  • JBoltAI：解锁企业AI数智化升级的Java利器
  • 算法与数据结构实战技巧：从复杂度分析到数学优化
  • 13-Java-面向对象-封装和this关键字
  • Jenkins运维之路(自动获得分支tag自动构建)
  • ComfyUI Easy - Use：简化ComfyUI操作的得力插件
  • echarts实现点击图表添加标记
  • MySQL MHA 高可用集群搭建
  • 5.物理服务器搭建FC
  • 决策树概念与原理
  • MySQL DBA需要掌握的 7 个问题
  • Windows权限提升（二）
  • 深蓝汽车人事调整：邓承浩升任董事长，姜海荣出任首席执行官
  • 【LeetCode热题100道笔记】对称二叉树
  • 跨域彻底讲透
  • ThinkPHP 6框架常见错误：htmlentities()函数参数类型问题解决
  • 【pyhton】函数
  • [Godot入门大全]目录
  • 【杂类】I/O
  • MiniDrive：面向自动驾驶的更高效的视觉语言模型
  • css 十大常用英文字体
  • Swift 解法详解 LeetCode 362：敲击计数器，让数据统计更高效
  • 2025高教社国赛数学建模A题参考论文35页（含代码和模型）
  • 【算法--链表】86.分割链表--通俗讲解
  • Linux基础知识(二)
  • Python毕业设计推荐：基于Django的饮食计划推荐与交流分享平台 饮食健康系统 健康食谱计划系统
  • Gutenberg块编辑器：WordPress 2025高效内容开发指南
  • 小智AI编译
  • Hadoop（八）