golang mssql 增删查改

发布时间:2024-12-23 00:06:42

Go语言是一种开源的编程语言，它在性能、并发特性和简洁性方面具有显著优势。随着企业业务的复杂性不断增加，对于数据存储和检索的需求也日益强烈。针对Microsoft SQL Server数据库，利用Golang进行增删查改操作是非常方便的。在本文中，我们将深入探讨如何使用Golang与Microsoft SQL Server进行交互，实现高效的数据操作。

连接数据库

首先，我们需要通过驱动程序来连接到Microsoft SQL Server数据库。可以使用微软提供的官方驱动程序“go-mssqldb”。该驱动程序可以通过以下命令获取：

go get github.com/denisenkom/go-mssqldb

然后，我们需要通过调用sql.Open()函数来建立与数据库的连接。代码示例如下：

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

func main() {
    server := "localhost"
    port := 1433
    user := "myuser"
    password := "mypassword"
    database := "mydb"

    connectionString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
        server, user, password, port, database)

    db, err := sql.Open("mssql", connectionString)
    if err != nil {
        fmt.Println(err.Error())
        return
    }

    defer db.Close()

    // 连接成功，可以进行后续操作
}

插入数据

一旦与数据库建立了连接，我们便可以开始插入数据。通过调用db.Exec()函数并传入相应的SQL语句，即可执行插入操作。代码示例如下：

func insertData(db *sql.DB) error {
    sql := "INSERT INTO users (name, age) VALUES ('John', 30)"

    _, err := db.Exec(sql)
    if err != nil {
        return err
    }

    return nil
}

在上述代码中，我们将数据插入到名为“users”的表中，将姓名和年龄字段设置为"John"和30。注意，在实际代码中，可以使用变量来代替固定的值。

查询数据

查询数据是与数据库交互中最常见的操作之一。通过调用db.Query()函数并传入相应的SQL语句，即可执行查询操作。代码示例如下：

type User struct {
    ID   int
    Name string
    Age  int
}

func queryData(db *sql.DB) ([]User, error) {
    sql := "SELECT id, name, age FROM users WHERE age > 25"

    rows, err := db.Query(sql)
    if err != nil {
        return nil, err
    }

    defer rows.Close()

    var users []User

    for rows.Next() {
        var user User
        err := rows.Scan(&user.ID, &user.Name, &user.Age)
        if err != nil {
            return nil, err
        }

        users = append(users, user)
    }

    return users, nil
}

在上述代码中，我们执行了一个SELECT语句，筛选出年龄大于25岁的用户的ID、姓名和年龄。通过rows.Scan()将查询结果映射到定义的结构体User中，最终将结果以切片形式返回。

更新数据

更新数据是对已存在的数据库记录进行修改的操作。通过调用db.Exec()函数并传入相应的SQL语句，即可执行更新操作。代码示例如下：

func updateData(db *sql.DB, userID int, newName string) error {
    sql := "UPDATE users SET name = ? WHERE id = ?"

    _, err := db.Exec(sql, newName, userID)
    if err != nil {
        return err
    }

    return nil
}

在上述代码中，我们将名为“users”的表中指定ID的用户的姓名更新为新值newName。通过在查询语句中使用问号占位符，可以便捷地将新值以参数形式传递。

删除数据

删除数据是对数据库记录进行永久性删除的操作。通过调用db.Exec()函数并传入相应的SQL语句，即可执行删除操作。代码示例如下：

func deleteData(db *sql.DB, userID int) error {
    sql := "DELETE FROM users WHERE id = ?"

    _, err := db.Exec(sql, userID)
    if err != nil {
        return err
    }

    return nil
}

在上述代码中，我们从名为“users”的表中删除指定ID的用户记录。同样地，可以使用问号占位符将参数传递给SQL语句。