Golang ilə MySQL verilənlər bazasında necə işləmək barədə təcrübəmi paylaşacağam. Aşağıdakı addımlarla həm MySQL serverinə necə qoşulacağınızı, həm də CRUD (yaratma, oxuma, yeniləmə, silmə) əməliyyatlarını, həmçinin hazırlanan ifadələr və transaction idarəetməsini nümunələrlə izah edəcəyəm.
1. Başlamazdan Əvvəl: Tələblər və Quraşdırma
Nə Lazımdır:
MySQL Serveri: İşlək bir MySQL verilənlər bazası (lokal və ya uzaq server).
Bu driver Golang-ın database/sql paketinin MySQL ilə işləməsini təmin edir.
2. Verilənlər Bazası ilə Əlaqə
İlk addımımız MySQL serverinə qoşulmaqdır. Bunun üçün DSN (Data Source Name) adlanan məlumatı müəyyən etmək lazımdır. DSN-də istifadəçi adı, parol, serverin ünvanı, port və verilənlər bazasının adı yer alır.
Qeyd:sql.Open funksiya ilə əlaqə yaradılır, amma əlaqənin həqiqətən işlədiyini db.Ping() ilə yoxlamaq vacibdir.
3. CRUD Əməliyyatları
a) Məlumat Əlavə Etmək (Create)
Yeni məlumat əlavə etmək üçün INSERT sorğusundan istifadə edirik.
// Məlumat əlavə etmək nümunəsi
query := "INSERT INTO users (name, email) VALUES (?, ?)"
result, err := db.Exec(query, "Khanbala", "khanbala@example.com")
if err != nil {
log.Fatal("Məlumat əlavə edilərkən xəta baş verdi:", err)
}
// Əlavə olunan son ID-ni əldə edirik
lastInsertID, err := result.LastInsertId()
if err != nil {
log.Fatal("Son əlavə olunan ID əldə edilərkən xəta:", err)
}
fmt.Println("Əlavə olunan məlumatınß ID-si:", lastInsertID)
b) Məlumat Oxumaq (Read)
Mövcud məlumatları oxumaq üçün SELECT sorğusunu istifadə edirik.
// Məlumat oxumaq nümunəsi
rows, err := db.Query("SELECT id, name, email FROM users")
if err != nil {
log.Fatal("Sorğu zamanı xəta baş verdi:", err)
}
defer rows.Close()
for rows.Next() {
var id int
var name, email string
if err := rows.Scan(&id, &name, &email); err != nil {
log.Fatal("Məlumat oxunarkən xəta:", err)
}
fmt.Printf("ID: %d, Name: %s, Email: %s\n", id, name, email)
}
// Satırların oxunması zamanı yaranan xətaları yoxlayırıq
if err := rows.Err(); err != nil {
log.Fatal("Oxuma zamanı xəta baş verdi:", err)
}
c) Məlumat Yeniləmək (Update)
Mövcud məlumat üzərində dəyişiklik etmək üçün UPDATE sorğusundan istifadə edirik.
// Məlumat yeniləmə nümunəsi
updateQuery := "UPDATE users SET email = ? WHERE id = ?"
res, err := db.Exec(updateQuery, "yeni_email@example.com", 1)
if err != nil {
log.Fatal("Yeniləmə zamanı xəta baş verdi:", err)
}
// Neçə sətirin yeniləndiyini öyrənirik
affectedRows, err := res.RowsAffected()
if err != nil {
log.Fatal("Əlavə edilən sətir sayını əldə edərkən xəta:", err)
}
fmt.Printf("Yenilənən sətir sayı: %d\n", affectedRows)
d) Məlumat Silmək (Delete)
Artıq lazım olmayan məlumatı silmək üçün DELETE sorğusu istifadə olunur.
// Məlumat silmə nümunəsi
deleteQuery := "DELETE FROM users WHERE id = ?"
res, err = db.Exec(deleteQuery, 1)
if err != nil {
log.Fatal("Silmə əməliyyatı zamanı xəta baş verdi:", err)
}
deletedRows, err := res.RowsAffected()
if err != nil {
log.Fatal("Silinən sətir sayını əldə edərkən xəta:", err)
}
fmt.Printf("Silinən sətir sayı: %d\n", deletedRows)
4. Hazırlanan İfadələr (Prepared Statements)
Təkrarlanan sorğular üçün hazırlanan ifadələr performansı artırır və SQL enjeksiyasının qarşısını alır. Gəlin, bir neçə məlumatı hazırlanan ifadə ilə necə əlavə edəcəyimizə baxaq.
// Hazırlanan ifadə ilə məlumat əlavə etmək
stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
if err != nil {
log.Fatal("İfadə hazırlanarkən xəta baş verdi:", err)
}
defer stmt.Close()
// Birdən çox istifadəçi əlavə etmək nümunəsi
users := []struct {
name string
email string
}{
{"Khanbala", "khanbala@example.com"},
}
for _, user := range users {
res, err := stmt.Exec(user.name, user.email)
if err != nil {
log.Println("Məlumat əlavə edilərkən xəta:", err)
continue
}
id, _ := res.LastInsertId()
fmt.Printf("Əlavə olunan istifadəçi ID-si: %d\n", id)
}
5. Transaction (Əməliyyat) İdarəetməsi
Transaction istifadə edərək, birdən çox əməliyyatın ya hamısının uğurla, ya da heç birinin tətbiq olunmasını təmin edirik. Bu, məlumatın tutarlılığını qorumağa kömək edir.
// Transaction başlatma
tx, err := db.Begin()
if err != nil {
log.Fatal("Transaction başladılarkən xəta:", err)
}
// İlk əməliyyat: məlumat əlavə etmək
_, err = tx.Exec("INSERT INTO users (name, email) VALUES (?, ?)", "Mushfig", "mushfig@example.com")
if err != nil {
tx.Rollback() // Xəta olduqda bütün əməliyyatları geri alırıq
log.Fatal("Transaction zamanı xəta (INSERT):", err)
}
// İkinci əməliyyat: məlumat yeniləmək
_, err = tx.Exec("UPDATE users SET email = ? WHERE name = ?", "mushfig_yeni@example.com", "Mushfig")
if err != nil {
tx.Rollback()
log.Fatal("Transaction zamanı xəta (UPDATE):", err)
}
// Transaction-u təsdiqləyirik
if err := tx.Commit(); err != nil {
log.Fatal("Transaction commit edilərkən xəta:", err)
}
fmt.Println("Transaction uğurla tamamlandı!")
6. Xəta İdarəetməsi və Ən Yaxşı Təcrübələr
Xəta Yoxlanışı: Hər əməliyyatdan sonra err yoxlayaraq proqramınızın möhkəm işləməsini təmin edin.
Bağlantı İdarəetməsi: İşiniz bitdikdən sonra defer db.Close() istifadə edərək açıq əlaqələrin düzgün bağlanmasını unutmayın.
Hazırlanan İfadələr: Təkrarlanan sorğularda hazırlanan ifadələrdən istifadə edərək həm təhlükəsizliyi, həm də performansı artırın.
Transaction İstifadəsi: Əməliyyatların bir-birinə bağlı olduğu hallarda transaction istifadə edin ki, hər hansı bir problem yarandıqda bütün əməliyyatlar geri alınsın.
