发布时间:2024-11-22 01:12:36
首先，我们知道在 Golang 中，可以使用第三方库来连接 MySQL 数据库。其中最常用且稳定的库是"database/sql"和"go-sql-driver/mysql"。在开始之前，确保你已经安装了这两个库。
要连接 MySQL 数据库，我们首先需要通过数据库驱动来建立连接。下面是一个简单的示例代码：
```go import ( "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" ) func main() { db, err := sql.Open("mysql", "root:@tcp(127.0.0.1:3306)/") if err != nil { panic(err.Error()) } defer db.Close() err = db.Ping() if err != nil { panic(err.Error()) } fmt.Println("成功连接到 MySQL 数据库！") } ```在上面的代码中，我们使用了 `sql.Open()` 方法来打开一个 MySQL 数据库连接。该方法接受两个参数，第一个参数是数据库驱动类型，这里我们使用的是"mysql"；第二个参数是数据库连接字符串，这里我们使用的是"root:@tcp(127.0.0.1:3306)/"，其中`root`表示用户名，后面跟着的`@tcp(127.0.0.1:3306)`表示数据库的地址和端口号，最后的斜杠表示不填写库名。
连接成功后，我们就可以执行各种 SQL 语句了。无论是查询、插入、更新还是删除，都可以通过`db.Exec()`方法来实现。下面是一个示例代码，演示如何创建一张表：
```go func createTable(db *sql.DB) { createTableSQL := ` CREATE TABLE IF NOT EXISTS products ( id INT AUTO_INCREMENT NOT NULL, name VARCHAR(50) NOT NULL, price decimal(10,2) NOT NULL, PRIMARY KEY (id) ); ` _, err := db.Exec(createTableSQL) if err != nil { panic(err) } fmt.Println("成功创建表！") } ```在这段代码中，我们使用了一个多行字符串将 SQL 语句保存下来。然后通过`db.Exec()`方法执行该 SQL 语句。如果执行过程中发生错误，我们会使用`panic()`来抛出异常。否则，说明表已成功创建。
除了创建表，我们还可以使用 Golang 来查询 MySQL 数据库中的数据。下面是一个简单的示例代码：
```go type Product struct { ID int Name string Price float64 } func queryData(db *sql.DB) { rows, err := db.Query("SELECT * FROM products") if err != nil { panic(err) } defer rows.Close() var products []Product for rows.Next() { var product Product err := rows.Scan(&product.ID, &product.Name, &product.Price) if err != nil { panic(err) } products = append(products, product) } if err = rows.Err(); err != nil { panic(err) } for _, product := range products { fmt.Println(product) } } ```在上述代码中，我们定义了一个名为`Product`的结构体，用于存储查询结果的每一行数据。然后使用`db.Query()`方法执行 SQL 查询语句，并通过`rows.Scan()`方法将查询结果映射到结构体中。最后将存储查询结果的结构体打印出来。
通过以上三个步骤，我们可以在 Golang 中连接 MySQL 数据库并进行各种操作，而无需填写具体的库名。希望本文对你有所帮助！