使用go-mssqldb连接Microsoft SQL Server数据库

go-mssqldb是Golang连接Microsoft SQL Server的官方推荐驱动，下面详细介绍其使用方法。

安装驱动

首先需要安装go-mssqldb驱动：

go get github.com/denisenkom/go-mssqldb

基本连接示例

package main

import (
    "database/sql"
    "fmt"
    "log"
    _ "github.com/denisenkom/go-mssqldb"
)

func main() {
    // 连接字符串格式
    // server=服务器地址;user id=用户名;password=密码;database=数据库名
    connString := "server=localhost;user id=sa;password=your_password;database=testdb;encrypt=disable"
    
    // 打开数据库连接
    db, err := sql.Open("sqlserver", connString)
    if err != nil {
        log.Fatal("连接数据库失败:", err.Error())
    }
    defer db.Close()
    
    // 测试连接
    err = db.Ping()
    if err != nil {
        log.Fatal("无法连接到数据库:", err.Error())
    }
    
    fmt.Println("成功连接到SQL Server数据库")
}

连接参数说明

连接字符串支持以下常用参数：

• server: 服务器地址(可以是IP或主机名)
• port: 端口号(默认1433)
• user id: 用户名
• password: 密码
• database: 数据库名
• encrypt: 是否加密(disable/true/false)
• connection timeout: 连接超时(秒)
• dial timeout: 拨号超时(秒)

执行查询

// 查询示例
func queryData(db *sql.DB) {
    rows, err := db.Query("SELECT id, name, age FROM users WHERE age > ?", 18)
    if err != nil {
        log.Fatal("查询失败:", err)
    }
    defer rows.Close()
    
    for rows.Next() {
        var id int
        var name string
        var age int
        err = rows.Scan(&id, &name, &age)
        if err != nil {
            log.Fatal("读取行失败:", err)
        }
        fmt.Printf("ID: %d, Name: %s, Age: %d\n", id, name, age)
    }
    
    if err = rows.Err(); err != nil {
        log.Fatal("遍历结果集出错:", err)
    }
}

执行插入/更新/删除

// 插入数据示例
func insertData(db *sql.DB) {
    result, err := db.Exec("INSERT INTO users (name, age) VALUES (?, ?)", "张三", 25)
    if err != nil {
        log.Fatal("插入失败:", err)
    }
    
    rowsAffected, err := result.RowsAffected()
    if err != nil {
        log.Fatal("获取影响行数失败:", err)
    }
    
    fmt.Printf("插入成功，影响行数: %d\n", rowsAffected)
}

使用事务

// 事务示例
func transactionExample(db *sql.DB) {
    tx, err := db.Begin()
    if err != nil {
        log.Fatal("开启事务失败:", err)
    }
    
    defer func() {
        if err != nil {
            tx.Rollback()
            return
        }
        tx.Commit()
    }()
    
    // 执行事务中的操作
    _, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", 100, 1)
    if err != nil {
        log.Println("更新账户1失败:", err)
        return
    }
    
    _, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", 100, 2)
    if err != nil {
        log.Println("更新账户2失败:", err)
        return
    }
    
    fmt.Println("事务执行成功")
}

处理NULL值

// 处理可能为NULL的列
func queryWithNull(db *sql.DB) {
    var name sql.NullString
    var age sql.NullInt64
    
    row := db.QueryRow("SELECT name, age FROM users WHERE id = ?", 1)
    err := row.Scan(&name, &age)
    if err != nil {
        log.Fatal("查询失败:", err)
    }
    
    if name.Valid {
        fmt.Println("Name:", name.String)
    } else {
        fmt.Println("Name is NULL")
    }
    
    if age.Valid {
        fmt.Println("Age:", age.Int64)
    } else {
        fmt.Println("Age is NULL")
    }
}

连接池配置

func main() {
    connString := "server=localhost;user id=sa;password=your_password;database=testdb"
    
    db, err := sql.Open("sqlserver", connString)
    if err != nil {
        log.Fatal(err)
    }
    defer db.Close()
    
    // 配置连接池
    db.SetMaxOpenConns(10)    // 最大打开连接数
    db.SetMaxIdleConns(5)     // 最大空闲连接数
    db.SetConnMaxLifetime(time.Hour) // 连接最大存活时间
    
    // 使用数据库...
}

注意事项

1. 对于Azure SQL Database，连接字符串需要添加;encrypt=true参数
2. 如果使用Windows身份验证，可以使用;trusted_connection=true代替用户名密码
3. 在生产环境中，建议将连接字符串配置在环境变量或配置文件中
4. 长时间运行的应用程序应该处理连接断开的场景，实现重连逻辑

通过以上示例，您应该能够使用go-mssqldb驱动在Golang中连接和操作SQL Server数据库了。