Golang CRUD demo

Setup your environment

  1. Make sure you have already installed and launched MatrixOne.

  2. Make sure you have already installed Golang 1.18 and plus.

    1. #To check with Golang installation and its version
    2. go version

  3. Make sure you have already installed MySQL client.

  4. Download and install Go-MySQL-Driver tool.

Develop your code

  1. Connect to MatrixOne by MySQL client. Create a new database named test.

    1. mysql> create database test;

  2. Create a plain text file golang_crud_matrixone.go and put the code below.

    1. package main
    3. import (
    4.     "database/sql"
    5.     "fmt"
    6.     "log"
    7.     _ "github.com/go-sql-driver/mysql"
    8. )
    10. func main() {
    11.     //Open a new connection to MatrixOne
    12.     db, err := sql.Open("mysql", "root:111@tcp(127.0.0.1:6001)/test")
    13.     checkErr(err)
    15.     //Create a table
    16.     _, err2 := db.Exec("CREATE TABLE `userinfo` (`uid` INT(10) NOT NULL AUTO_INCREMENT,`username` VARCHAR(64) NULL DEFAULT NULL,`department` VARCHAR(64) NULL DEFAULT NULL,`created` DATETIME NULL DEFAULT NULL, PRIMARY KEY (`uid`));")
    17.     if err2 != nil {
    18.         log.Fatal(err2)
    19.     }
    20.     fmt.Print("Successfully Created\n")
    22.     // Insert a record
    23.     stmt, err := db.Prepare("INSERT userinfo SET username=?,department=?,created=?")
    24.     checkErr(err)
    26.     res, err := stmt.Exec("Alex", "r&d", "2023-01-01" 12:00:00")
    27.     checkErr(err)
    29.     id, err := res.LastInsertId()
    30.     checkErr(err)
    32.     fmt.Println(id)
    33.     //Update a record
    34.     stmt, err = db.Prepare("update userinfo set username=? where uid=?")
    35.     checkErr(err)
    37.     res, err = stmt.Exec("Mark", id)
    38.     checkErr(err)
    40.     affect, err := res.RowsAffected()
    41.     checkErr(err)
    43.     fmt.Println(affect)
    45.     // Query all records
    46.     rows, err := db.Query("SELECT * FROM userinfo")
    47.     checkErr(err)
    49.     for rows.Next() {
    50.         var uid int
    51.         var username string
    52.         var department string
    53.         var created string
    54.         err = rows.Scan(&uid, &username, &department, &created)
    55.         checkErr(err)
    56.         fmt.Println(uid)
    57.         fmt.Println(username)
    58.         fmt.Println(department)
    59.         fmt.Println(created)
    60.     }
    62.     // Delete a record
    63.     stmt, err = db.Prepare("delete from userinfo where uid=?")
    64.     checkErr(err)
    66.     res, err = stmt.Exec(id)
    67.     checkErr(err)
    69.     affect, err = res.RowsAffected()
    70.     checkErr(err)
    72.     fmt.Println(affect)
    74.     db.Close()
    76. }
    78. func checkErr(err error) {
    79.     if err != nil {
    80.         panic(err)
    81.     }
    82. }

  3. Execute this Golang file in the command line terminal.

    1. > go run golang_crud_matrixone.go
    2. Successfully Created
    3. 1
    4. 1
    5. 1
    6. Mark
    7. r&d
    8. 2023-01-01
    9. 1