From 82954508e0ce494c141d1a9b49826832e4986eac Mon Sep 17 00:00:00 2001
From: loshiqi <553578653@qq.com>
Date: Tue, 15 Jul 2025 15:09:14 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A9=B1=E5=8A=A8=E5=90=8D=E7=A7=B0=20?=
 =?UTF-8?q?=E6=9B=B4=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 conn.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/conn.go b/conn.go
index 9c22972..ca4bd88 100644
--- a/conn.go
+++ b/conn.go
@@ -12,6 +12,7 @@ import (
 
 	_ "gitee.com/opengauss/openGauss-connector-go-pq" // 高斯驱动（推荐）或 "github.com/lib/pq"
 	_ "github.com/go-sql-driver/mysql"
+	//_ "github.com/lib/pq" // 关键驱动导入
 )
 
 var DB *sql.DB
@@ -159,8 +160,9 @@ func PgConnect(DBHOST, DBUSER, DBPWD, DBNAME, DBPORT string, conns ...int) error
 	var dbConnErr error
 	if DBHOST != "" && DBUSER != "" && DBPWD != "" && DBPORT != "" { //&& DBNAME != ""
 		dsn := "host=" + DBHOST + " port=" + DBPORT + " user=" + DBUSER + " password=" + DBPWD + " dbname=" + DBNAME + " sslmode=disable search_path=public"
+		log.Println("database dsn", dsn)
 		for i := 0; i < 10; i++ {
-			DB, dbConnErr = sql.Open("postgres", dsn)
+			DB, dbConnErr = sql.Open("opengauss", dsn)
 			if dbConnErr != nil {
 				log.Println("ERROR", "can not connect to pg Database, ", dbConnErr)
 				time.Sleep(time.Second * 5)