Bagaimana golang mengendalikan data mysql

Apakah MySQL

MySQL, dibangunkan di bawah tajaan Oracle Corporation, ialah sistem pengurusan pangkalan data hubungan yang digunakan secara meluas dalam infrastruktur Internet. Ia menyokong berbilang sistem pengendalian dan bahasa pengaturcaraan, termasuk bahasa Go, dan mempunyai satu siri ciri yang menyokong penyepaduan data yang besar dan pertanyaan berprestasi tinggi.

MySQL menggunakan struktur data berasaskan jadual, dengan setiap baris mewakili rekod dan setiap lajur mewakili medan. Ia menggunakan bahasa SQL untuk beroperasi pada data, operasi SQL yang paling biasa termasuk SELECT, INSERT, UPDATE, DELETE dan CREATE TABLE.

Pemacu MySQL dalam bahasa Go

Dalam bahasa Go, kami boleh menggunakan pemacu MySQL pihak ketiga untuk menyambung dan menanyakan pangkalan data MySQL. Walau bagaimanapun, perpustakaan standard bahasa GO sudah mengandungi pakej database/sql, yang telah melaksanakan antara muka pangkalan data SQL standard dan boleh beroperasi antara pangkalan data SQL lain yang mudah dan popular, termasuk MySQL, PostgreSQL dan SQLite.

Jadi, sebelum kita mula membina aplikasi Go yang menanyakan MySQL, kita perlu memasang pemacu MySql. Anda boleh menggunakan arahan baris arahan go get -u github.com/go-sql-driver/mysql untuk pemasangan pantas.

Ini kerana dalam bahasa Go, semua akses data perlu dilakukan melalui sambungan SQL.DB. Dan tujuan pemandu adalah untuk melaksanakan konvensyen antara muka seperti fungsi database/sql.

Mewujudkan sambungan

Dalam bahasa Go, mewujudkan sambungan ke pangkalan data MySQL adalah berdasarkan rentetan sambungan Rentetan sambungan mengandungi semua parameter yang diperlukan untuk menyambung kepada MySQL Seperti nama pengguna, kata laluan, nama hos atau alamat IP, nombor port dan nama pangkalan data, dsb.

db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
if err != nil {
    log.Fatal(err)
}

Data pertanyaan

Dalam bahasa Go, anda boleh menggunakan fungsi db.Query(), db.QueryRow() dan db.Exec() untuk bertanya dan memanipulasi data dalam MySQL pangkalan data. Fungsi

db.Query() digunakan untuk menanyakan berbilang rekod dan mengembalikan objek *sql.Rows. Fungsi db.QueryRow() digunakan untuk menanyakan satu rekod dan mengembalikan objek *sql.Row, serupa dengan resultset, tetapi ia hanya mengembalikan baris pertama rekod dan biasanya digunakan untuk menanyakan satu rekod unik. Fungsi db.Exec() digunakan untuk melaksanakan pernyataan SQL bukan pertanyaan seperti INSERT, UPDATE dan DELETE, mengembalikan objek sql.Result.

Dalam contoh ini, kami menggunakan fungsi db.Query() untuk menanyakan semua rekod. Kami akan menggunakan kaunter mudah untuk mengira bilangan rekod dan mencetak setiap baris data ke konsol.

rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

count := 0
for rows.Next() {
    var id int
    var name string
    if err := rows.Scan(&id, &name); err != nil {
        log.Fatal(err)
    }
    fmt.Printf("id=%d, name=%s\n", id, name)
    count++
}
if err := rows.Err(); err != nil {
    log.Fatal(err)
}

fmt.Printf("Found %d users\n", count)

mesti memanggil fungsi rows.Close() selepas mendapatkan data untuk melepaskan sumber pangkalan data yang dikaitkan dengan *sql.Rows. Selain itu, kod menggunakan fungsi rows.Next(), yang mengembalikan nilai Boolean yang menunjukkan sama ada terdapat lebih banyak baris untuk diproses. Selain itu, fungsi rows.Scan() digunakan dalam contoh ini untuk menyalin nilai yang direkodkan dalam setiap baris ke dalam pembolehubah id dan name yang ditakrifkan dalam contoh ini, dan kemudian mencetak setiap nilai dalam konsol.

Sisipkan data

Kami juga boleh menggunakan bahasa Go untuk memasukkan data ke dalam pangkalan data MySQL Cara paling mudah ialah menggunakan fungsi db.Exec(). Kita boleh menghantar pernyataan sisip ke dalam fungsi db.Exec() dan ia akan dilaksanakan dalam MySQL sebagai pernyataan SQL.

result, err := db.Exec("INSERT INTO users(name, email) VALUES('John Doe', 'johndoe@gmail.com')")
if err != nil {
    log.Fatal(err)
}

rowsAffected, err := result.RowsAffected()
if err != nil {
    log.Fatal(err)
}
fmt.Printf("Inserted %d rows into users table\n", rowsAffected)

Kita boleh menggunakan result.RowsAffected() untuk mendapatkan bilangan baris yang terjejas dalam set hasil dan menggunakan nilai itu untuk mencetak bilangan data yang dikemas kini dalam konsol.

Atas ialah kandungan terperinci Bagaimana golang mengendalikan data mysql. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!