Golang MySQL CRUD示例

怼烎@ 2023-10-04 13:58 37阅读 0赞

在本教程中，我们将看到一个示例程序，以学习如何使用Golang和MySQL进行数据库CRUD操作。CRUD是“创建”，“读取”，“更新”和“删除”的首字母缩写。CRUD操作是数据库的基本数据操作。  
在此示例中，我们将创建一个接口作为数据库前端来处理这些操作。我们有Employee表，其中包含诸如id，姓名和城市之类的员工信息。使用此表，我们必须使用MySQL执行CRUD。

步骤1：准备并将MySQL驱动程序导入项目

使用Git Bash首先为Go的MySQL数据库软件包安装驱动程序。运行以下命令并安装MySQL驱动程序

go get -u github.com/go-sql-driver/mysql

现在创建Goblog数据库

1.打开MySQL数据库管理工具。  
2.创建一个新的数据库“ goblog”

--------------------

步骤2：建立Employee表

执行以下SQL查询，以在MySQL数据库中创建一个名为Employee的表。我们将在以后的所有操作中使用此表。

DROP TABLE IF EXISTS `employee`;
    CREATE TABLE `employee` (
      `id` int(6) unsigned NOT NULL AUTO_INCREMENT,
      `name` varchar(30) NOT NULL,
      `city` varchar(30) NOT NULL,
      PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=latin1;

--------------------

步骤3：创建结构，处理程序和处理程序功能

让我们创建一个名为的文件`main.go`，并将以下代码放入其中。  
我们通常导入数据库/ sql，并使用sql在数据库上执行数据库查询。  
函数`dbConn`打开与MySQL驱动程序的连接。  
我们将创建`Employee`具有以下属性的结构：Id，名称和城市。

package main
    
    import (
        "database/sql"
        "log"
        "net/http"
        "text/template"
    
        _ "github.com/go-sql-driver/mysql"
    )
    
    type Employee struct {
        Id    int
        Name  string
        City string
    }
    
    func dbConn() (db *sql.DB) {
        dbDriver := "mysql"
        dbUser := "root"
        dbPass := "root"
        dbName := "goblog"
        db, err := sql.Open(dbDriver, dbUser+":"+dbPass+"@/"+dbName)
        if err != nil {
            panic(err.Error())
        }
        return db
    }
    
    var tmpl = template.Must(template.ParseGlob("form/*"))
    
    func Index(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        selDB, err := db.Query("SELECT * FROM Employee ORDER BY id DESC")
        if err != nil {
            panic(err.Error())
        }
        emp := Employee{}
        res := []Employee{}
        for selDB.Next() {
            var id int
            var name, city string
            err = selDB.Scan(&id, &name, &city)
            if err != nil {
                panic(err.Error())
            }
            emp.Id = id
            emp.Name = name
            emp.City = city
            res = append(res, emp)
        }
        tmpl.ExecuteTemplate(w, "Index", res)
        defer db.Close()
    }
    
    func Show(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        nId := r.URL.Query().Get("id")
        selDB, err := db.Query("SELECT * FROM Employee WHERE id=?", nId)
        if err != nil {
            panic(err.Error())
        }
        emp := Employee{}
        for selDB.Next() {
            var id int
            var name, city string
            err = selDB.Scan(&id, &name, &city)
            if err != nil {
                panic(err.Error())
            }
            emp.Id = id
            emp.Name = name
            emp.City = city
        }
        tmpl.ExecuteTemplate(w, "Show", emp)
        defer db.Close()
    }
    
    func New(w http.ResponseWriter, r *http.Request) {
        tmpl.ExecuteTemplate(w, "New", nil)
    }
    
    func Edit(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        nId := r.URL.Query().Get("id")
        selDB, err := db.Query("SELECT * FROM Employee WHERE id=?", nId)
        if err != nil {
            panic(err.Error())
        }
        emp := Employee{}
        for selDB.Next() {
            var id int
            var name, city string
            err = selDB.Scan(&id, &name, &city)
            if err != nil {
                panic(err.Error())
            }
            emp.Id = id
            emp.Name = name
            emp.City = city
        }
        tmpl.ExecuteTemplate(w, "Edit", emp)
        defer db.Close()
    }
    
    func Insert(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        if r.Method == "POST" {
            name := r.FormValue("name")
            city := r.FormValue("city")
            insForm, err := db.Prepare("INSERT INTO Employee(name, city) VALUES(?,?)")
            if err != nil {
                panic(err.Error())
            }
            insForm.Exec(name, city)
            log.Println("INSERT: Name: " + name + " | City: " + city)
        }
        defer db.Close()
        http.Redirect(w, r, "/", 301)
    }
    
    func Update(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        if r.Method == "POST" {
            name := r.FormValue("name")
            city := r.FormValue("city")
            id := r.FormValue("uid")
            insForm, err := db.Prepare("UPDATE Employee SET name=?, city=? WHERE id=?")
            if err != nil {
                panic(err.Error())
            }
            insForm.Exec(name, city, id)
            log.Println("UPDATE: Name: " + name + " | City: " + city)
        }
        defer db.Close()
        http.Redirect(w, r, "/", 301)
    }
    
    func Delete(w http.ResponseWriter, r *http.Request) {
        db := dbConn()
        emp := r.URL.Query().Get("id")
        delForm, err := db.Prepare("DELETE FROM Employee WHERE id=?")
        if err != nil {
            panic(err.Error())
        }
        delForm.Exec(emp)
        log.Println("DELETE")
        defer db.Close()
        http.Redirect(w, r, "/", 301)
    }
    
    func main() {
        log.Println("Server started on: http://localhost:8080")
        http.HandleFunc("/", Index)
        http.HandleFunc("/show", Show)
        http.HandleFunc("/new", New)
        http.HandleFunc("/edit", Edit)
        http.HandleFunc("/insert", Insert)
        http.HandleFunc("/update", Update)
        http.HandleFunc("/delete", Delete)
        http.ListenAndServe(":8080", nil)
    }

--------------------

步骤4：创建模板文件

现在是时候构建我们的CRUD应用程序的模板文件了。`form`在我们创建的位置创建文件夹`main.go`。

a）让我们`Index.tmpl`在`form`文件夹内创建一个名为的文件，并将以下代码放入其中。

{
       { define "Index" }}
      {
       { template "Header" }}
        {
       { template "Menu"  }}
        <h2> Registered </h2>
        <table border="1">
          <thead>
          <tr>
            <td>ID</td>
            <td>Name</td>
            <td>City</td>
            <td>View</td>
            <td>Edit</td>
            <td>Delete</td>
          </tr>
           </thead>
           <tbody>
        {
       { range . }}
          <tr>
            <td>{
       { .Id }}</td>
            <td> {
       { .Name }} </td>
            <td>{
       { .City }} </td> 
            <td><a href="/show?id={
       { .Id }}">View</a></td>
            <td><a href="/edit?id={
       { .Id }}">Edit</a></td>
            <td><a href="/delete?id={
       { .Id }}">Delete</a><td>
          </tr>
        {
       { end }}
           </tbody>
        </table>
      {
       { template "Footer" }}
    {
       { end }}

b）现在，`Header.tmpl`在同一个`form`文件夹内创建另一个文件，并将以下代码放入其中。

{
       { define "Header" }}
    <!DOCTYPE html>
    <html lang="en-US">
        <head>
            <title>Golang Mysql Curd Example</title>
            <meta charset="UTF-8" />
        </head>
        <body>
            <h1>Golang Mysql Curd Example</h1>   
    {
       { end }}

c）现在，`Footer.tmpl`在同一个`form`文件夹内创建另一个名为的文件，并将以下代码放入其中。

{
       { define "Footer" }}
        </body>
    </html>
    {
       { end }}

d）现在，`Menu.tmpl`在同一个`form`文件夹内创建另一个名为的文件，并将以下代码放入其中。

{
       { define "Menu" }}
    <a href="/">HOME</a> | 
    <a href="/new">NEW</a>
    {
       { end }}

e）接下来，我们必须`Show.tmpl`为项目详细信息页面创建文件，因此再次在`form`文件夹中创建此文件。

{
       { define "Show" }}
      {
       { template "Header" }}
        {
       { template "Menu"  }}
        <h2> Register {
       { .Id }} </h2>
          <p>Name: {
       { .Name }}</p>
          <p>City:  {
       { .City }}</p><br /> <a href="/edit?id={
       { .Id }}">Edit</a></p>
      {
       { template "Footer" }}
    {
       { end }}

f）现在我们创建用于创建新物品的新刀刃文件，它是`New.tmpl`内部的调用文件`form`。

{
       { define "New" }}
      {
       { template "Header" }}
        {
       { template "Menu" }} 
       <h2>New Name and City</h2>  
        <form method="POST" action="insert">
          <label> Name </label><input type="text" name="name" /><br />
          <label> City </label><input type="text" name="city" /><br />
          <input type="submit" value="Save user" />
        </form>
      {
       { template "Footer" }}
    {
       { end }}

g）最后，我们需要`Edit.tmpl`为更新项目创建文件，因此再次在`form`文件夹中创建此文件。

{
       { define "Edit" }}
      {
       { template "Header" }}
        {
       { template "Menu" }} 
       <h2>Edit Name and City</h2>  
        <form method="POST" action="update">
          <input type="hidden" name="uid" value="{
       { .Id }}" />
          <label> Name </label><input type="text" name="name" value="{
       { .Name }}"  /><br />
          <label> City </label><input type="text" name="city" value="{
       { .City }}"  /><br />
          <input type="submit" value="Save user" />
        </form><br />    
      {
       { template "Footer" }}
    {
       { end }}

--------------------

经过漫长的旅程，我们终于使用Golang和MySQL创建了CRUD应用程序的所有文件。

![带有Golang和MySQL的CRUD应用程序][Golang_MySQL_CRUD]

![带有Golang和MySQL的CRUD应用程序][Golang_MySQL_CRUD 1]

--------------------

运行以下命令

go run main.go

--------------------

加载以下URL

http://localhost:8080/

[Golang_MySQL_CRUD]: https://img-blog.csdnimg.cn/img_convert/9d96048b87c61ba1910951764e546740.png
[Golang_MySQL_CRUD 1]: https://img-blog.csdnimg.cn/img_convert/03ea90c05ca524fe26e6c82b28ba3760.png