godror - Golang高性能Oracle数据库驱动使用指南

godror是Oracle官方推荐的Go语言Oracle数据库驱动，基于Oracle的ODPI-C接口实现，具有高性能和稳定性。下面详细介绍其使用方法。

安装

go get github.com/godror/godror

需要先安装Oracle客户端库，并设置相关环境变量：

1. 下载Oracle Instant Client Basic或Basic Light包
2. 解压并设置LD_LIBRARY_PATH(linux)或PATH(windows)

基本使用

连接数据库

package main

import (
	"database/sql"
	"fmt"
	"log"
	_ "github.com/godror/godror"
)

func main() {
	// 连接字符串格式: user/pass@host:port/service_name
	dsn := "scott/tiger@localhost:1521/ORCLPDB1?connect_timeout=30"
	db, err := sql.Open("godror", dsn)
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

	// 测试连接
	err = db.Ping()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("Connected to Oracle database successfully!")
}

查询数据

func queryData(db *sql.DB) {
	rows, err := db.Query("SELECT employee_id, first_name, last_name FROM employees WHERE department_id = :1", 50)
	if err != nil {
		log.Fatal(err)
	}
	defer rows.Close()

	for rows.Next() {
		var (
			id        int
			firstName string
			lastName  string
		)
		if err := rows.Scan(&id, &firstName, &lastName); err != nil {
			log.Fatal(err)
		}
		fmt.Printf("ID: %d, Name: %s %s\n", id, firstName, lastName)
	}

	if err := rows.Err(); err != nil {
		log.Fatal(err)
	}
}

执行DML操作

func insertData(db *sql.DB) {
	result, err := db.Exec(
		"INSERT INTO employees (employee_id, first_name, last_name, email, hire_date, job_id) "+
			"VALUES (:1, :2, :3, :4, :5, :6)",
		207, "John", "Doe", "JDOE", time.Now(), "IT_PROG")
	if err != nil {
		log.Fatal(err)
	}

	rowsAffected, err := result.RowsAffected()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Printf("Inserted %d row(s)\n", rowsAffected)
}

高级特性

批量插入

func batchInsert(db *sql.DB) {
	// 准备语句
	stmt, err := db.Prepare("INSERT INTO employees (employee_id, first_name, last_name) VALUES (:1, :2, :3)")
	if err != nil {
		log.Fatal(err)
	}
	defer stmt.Close()

	// 批量插入
	for i := 0; i < 10; i++ {
		_, err = stmt.Exec(300+i, fmt.Sprintf("First%d", i), fmt.Sprintf("Last%d", i))
		if err != nil {
			log.Fatal(err)
		}
	}
}

事务处理

func transactionExample(db *sql.DB) {
	tx, err := db.Begin()
	if err != nil {
		log.Fatal(err)
	}

	// 执行事务操作
	_, err = tx.Exec("UPDATE accounts SET balance = balance - 100 WHERE account_id = 1")
	if err != nil {
		tx.Rollback()
		log.Fatal(err)
	}

	_, err = tx.Exec("UPDATE accounts SET balance = balance + 100 WHERE account_id = 2")
	if err != nil {
		tx.Rollback()
		log.Fatal(err)
	}

	err = tx.Commit()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("Transaction completed successfully")
}

使用Oracle特有类型

func oracleTypesExample(db *sql.DB) {
	var (
		id      int
		name    string
		hireDate time.Time
		salary  float64
		photo   []byte
	)
	
	err := db.QueryRow(`
		SELECT employee_id, first_name, hire_date, salary, photo 
		FROM employees 
		WHERE employee_id = :1`, 100).Scan(&id, &name, &hireDate, &salary, &photo)
	if err != nil {
		log.Fatal(err)
	}
	
	fmt.Printf("ID: %d, Name: %s, Hire Date: %v, Salary: %.2f, Photo Size: %d\n",
		id, name, hireDate, salary, len(photo))
}

性能优化技巧

1. 连接池配置：

db.SetMaxOpenConns(25)  // 最大连接数
db.SetMaxIdleConns(5)   // 最大空闲连接数
db.SetConnMaxLifetime(time.Hour)  // 连接最大存活时间

1. 使用预编译语句：重复执行的SQL应使用Prepare

2. 批量操作：使用数组绑定提高批量操作性能

3. 适当设置fetch size：

rows, err := db.Query("SELECT /*+ godror.fetchSize=100 */ * FROM large_table")

1. 使用连接上下文：

ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()

rows, err := db.QueryContext(ctx, "SELECT * FROM slow_query")

常见问题解决

1. ORA-12545: Connect failed because target host or object does not exist

   • 检查连接字符串格式
   • 确认Oracle监听服务运行正常

2. ORA-01017: invalid username/password; logon denied

   • 检查用户名密码
   • 确认用户有连接权限

3. DPI-1047: Oracle Client library cannot be loaded

   • 确认Oracle Instant Client已安装
   • 检查环境变量设置

godror提供了高性能的Oracle数据库访问能力，通过合理配置和使用其高级特性，可以满足企业级应用的需求。更多详细配置和选项请参考官方文档。