go言語を搭載したデータベースは何ですか?

このチュートリアルの動作環境: Windows 7 システム、GO バージョン 1.18、Dell G3 コンピューター。

golang はさまざまなデータベースをサポートしています

1. MySQL

MySQL はリレーショナル データベース管理システムです。MySQL は With を採用しています。二重認可ポリシーにより、データを異なるテーブルに保存できるため、データベースの速度と柔軟性が向上し、サイズが小さく、速度が速く、総所有コストが低いという特徴があります。

2. Oracle

oracle は、データベース分野で主導的な地位にあるリレーショナル データベース管理システムであり、優れた移植性、使いやすさ、強力な機能という特徴を備えています。大規模、中小規模、マイコン環境で利用できる高効率、高信頼性、高スループットのデータベースであり、さまざまな用途に適しています。

3. SQLite

SQLite は、ACID リレーショナル データベース管理システムに準拠した軽量データベースです。組み込み用途向けに設計されています。SQLite は多くの組み込み製品で使用できます。 C#、PHP、Java、その他のプログラミング言語と組み合わせて使用​​できます。

4. MongoDB

MongoDB は、分散ファイル ストレージに基づくデータベースです。その目的は、Web アプリケーションにスケーラブルで高性能のデータ ストレージ ソリューションを提供することです。MongoDB によってサポートされるデータ構造は、非常に高度です。また、複数のクエリ言語とインデックス作成をサポートしています。

5. PostgreSQL

PostgreSQL は、複雑なクエリ、外部キー、トリガー、ビュー、トランザクションの整合性、および複数のバージョンを備えた、強力なオープンソースのオブジェクト リレーショナル データベース管理システムです。同時実行制御、PostgreSQL は関数を通じてデータベース サーバー上で命令プログラムを実行でき、ユーザーはインデックス メソッドをカスタマイズできます。

6. SQL サーバー

SQL サーバーはリレーショナル データベース管理システムであり、使いやすさ、優れた拡張性、関連ソフトウェアの高度な統合という利点があり、より安全でより多くの機能を提供できます。信頼性の高いストレージ、パフォーマンス、SQL Server を使用して、ビジネス向けの可用性とパフォーマンスの高いデータ アプリケーションを構築および管理します。

Golang は MySQL データベースを操作します

以下では主に Go 言語における mysql の使い方を追加、削除、クエリ、変更の側面から紹介します。

1. データベースに接続します

sql.Open() 関数を使用してデータベース接続を開きます。データベース接続文字列 (dsn) の形式は次のとおりです。

admin:123456@tcp(10.2.1.5)/irisapp

コードは次のとおりです:

func (f *mysql_db) mysql_open() {
    db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)
    if err != nil {
        fmt.Println("链接失败")
    }
    fmt.Println("链接成功")
    f.db = db
}

2. 挿入

func (f *mysql_db) mysql_insert() { //insert  添加数据
    fmt.Println("开始插入")
    stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")
    //defer stmt.Close()
    if err != nil {
        fmt.Println("插入失败")
        return
    }
    stmt.Exec("dd", "adadcccda")
    fmt.Println("插入成功")
}

3. クエリ

func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据
    fmt.Println("sql:", sql_data)
    rows, err := f.db.Query(sql_data)
    if err != nil {
        fmt.Println("查询失败")
    }
    for rows.Next() {
        var departID int
        var departName string
        var memo string
        err = rows.Scan(&departID, &departName, &memo)
        if err != nil {
            panic(err)
        }
        fmt.Println("departName:", departName)
    }
}

4. 更新

func (f *mysql_db) mysql_update() { //update  修改数据
    stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")
    //defer stmt.Close()
    if err != nil {
        //错误处理
    }
    result,_ := stmt.Exec("aa","asdfadsadsfa",1)
    if result == nil {
        fmt.Println("修改失败")
    }
    affect_count,_ := result.RowsAffected()    //返回影响的条数,注意有两个返回值
    fmt.Println("%v",affect_count)
}

5. 削除

func (f *mysql_db) mysql_delete() { //delete  删除数据
    stmt, err := f.db.Prepare("delete from depart where departId=?")
    //defer stmt.Close()
    if err != nil {
        //错误处理
    }
    stmt.Exec(2)     //不返回任何结果
    fmt.Println("删除成功")
}

6. 物事

func (f *mysql_db) mysql_tran(){
    //事务
    tx,err := f.db.Begin()        //声明一个事务的开始
    if err != nil {
        fmt.Println(err)
        return
    }
    insert_sql := "insert into depart (departName,memo) VALUES(?,?)"
    insert_stmt,insert_err := tx.Prepare(insert_sql)
    if insert_err != nil {
        fmt.Println(insert_err)
        return
    }
    insert_res,insert_err := insert_stmt.Exec("ff","ff")
    last_insert_id,_ := insert_res.LastInsertId()
    fmt.Println(last_insert_id)
    // defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的
    tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据
}

Call

func main() {
    db := &mysql_db{}
    db.mysql_open()
    db.mysql_insert()
    db.mysql_update()
    db.mysql_delete()
    db.mysql_tran()
    db.mysql_select("select departID,departName,memo from depart")
    db.mysql_close() //关闭
}

起動後の出力は次のとおりです。

D:\Go_Path\go\src\mysqldemo>go run mysqldemo.go
链接成功
开始插入
插入成功
0
删除成功
10
sql: select departID,departName,memo from depart
departName: aa
departName: dd
departName: dd
departName: dd
departName: dd
departName: dd
departName: ff
departName: dd
departName: ff

完全なコード

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    )

var (
    dbhostsip  = "10.2.1.5:3306"
    dbusername = "admin"
    dbpassword = "123456"
    dbname     = "irisapp"
)

type mysql_db struct {
    db *sql.DB
}

func (f *mysql_db) mysql_open() {
    db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)
    if err != nil {
        fmt.Println("链接失败")
    }
    fmt.Println("链接成功")
    f.db = db
}

func (f *mysql_db) mysql_close() {
    defer f.db.Close()
}

func (f *mysql_db) mysql_select(sql_data string) {   //select 查询数据
    fmt.Println("sql:", sql_data)
    rows, err := f.db.Query(sql_data)
    if err != nil {
        fmt.Println("查询失败")
    }
    for rows.Next() {
        var departID int
        var departName string
        var memo string
        err = rows.Scan(&departID, &departName, &memo)
        if err != nil {
            panic(err)
        }
        fmt.Println("departName:", departName)
    }

}

func (f *mysql_db) mysql_insert() { //insert  添加数据
    fmt.Println("开始插入")
    stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")
    //defer stmt.Close()
    if err != nil {
        fmt.Println("插入失败")
        return
    }
    stmt.Exec("dd", "adadcccda")
    fmt.Println("插入成功")
}

func (f *mysql_db) mysql_update() { //update  修改数据
    stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")
    //defer stmt.Close()
    if err != nil {
        //错误处理
    }
    result,_ := stmt.Exec("aa","asdfadsadsfa",1)
    if result == nil {
        fmt.Println("修改失败")
    }
    affect_count,_ := result.RowsAffected()    //返回影响的条数,注意有两个返回值
    fmt.Println(affect_count)
}

func (f *mysql_db) mysql_delete() { //delete  删除数据
    stmt, err := f.db.Prepare("delete from depart where departId=?")
    //defer stmt.Close()
    if err != nil {
        //错误处理
    }
    stmt.Exec(2)     //不返回任何结果
    fmt.Println("删除成功")
}

func (f *mysql_db) mysql_tran(){
    //事务
    tx,err := f.db.Begin()        //声明一个事务的开始
    if err != nil {
        fmt.Println(err)
        return
    }
    insert_sql := "insert into depart (departName,memo) VALUES(?,?)"
    insert_stmt,insert_err := tx.Prepare(insert_sql)
    if insert_err != nil {
        fmt.Println(insert_err)
        return
    }
    insert_res,insert_err := insert_stmt.Exec("ff","ff")
    last_insert_id,_ := insert_res.LastInsertId()
    fmt.Println(last_insert_id)
    // defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在与数据库表中的
    tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据
}

func main() {
    db := &mysql_db{}
    db.mysql_open()
    db.mysql_insert()
    db.mysql_update()
    db.mysql_delete()
    db.mysql_tran()
    db.mysql_select("select departID,departName,memo from depart")
    db.mysql_close() //关闭

}

概要

1. SQL クエリを最適化してパフォーマンスを向上させ、SQL インジェクションのリスクを軽減するために使用できる準備式のサポート db.Prepare() と tx.Prepare は両方とも、準備された式のサポートを提供します。

2. LastInsertId() 最初に挿入されたアイテムの ID を取得します

3. RowsAffected() 影響を受ける/挿入されたアイテムの数を取得します

4. ここでは単なるgo の簡単な紹介 Go 言語開発における MySQL の基本的な使い方 実際の開発プロセスでは、ORM 関連のサードパーティ フレームワークが主に使用されますが、基礎となる原則を学ぶ必要があります。

Go 言語の知識について詳しくは、PHP 中国語 Web サイトの go 言語チュートリアル 列に注目してください。

以上がgo言語を搭載したデータベースは何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。