Go ile MongoDB Kullanımı: MongoDB Go Driver Rehberi

Go ile MongoDB Kullanımı: MongoDB Go Driver Rehberi

Bu makalede, popüler NoSQL veritabanı MongoDB ile Go programlama dilini kullanarak nasıl etkili bir şekilde etkileşim kurabileceğinizi detaylı bir şekilde ele alacağız. MongoDB’nin esnek yapısı ve Go’nun performansıyla birleşimi, modern web uygulamaları, mikroservisler ve veri odaklı projeler için güçlü bir çözüm sunar. Bu rehberde, MongoDB Go Driver’ın kurulumundan başlayarak temel CRUD (Create, Read, Update, Delete) işlemlerine, indeksleme, sorgulama ve hata yönetimi gibi daha gelişmiş konulara kadar geniş bir yelpazede bilgi bulacaksınız.

MongoDB ve Go Ekosistemine Giriş

MongoDB, belgeler tabanlı (document-oriented) bir NoSQL veritabanıdır. İlişkisel veritabanlarının aksine, MongoDB şema esnekliği sunar ve verileri JSON benzeri BSON (Binary JSON) formatında depolar. Bu, geliştiricilerin verilerini daha doğal ve esnek bir şekilde modellemelerine olanak tanır.

Go (veya Golang), Google tarafından geliştirilmiş, derlenmiş, statik tipli ve eşzamanlı programlama yetenekleriyle öne çıkan bir dildir. Performansı, basitliği ve güçlü standart kütüphanesi sayesinde sistem programcılığından web geliştirmeye kadar geniş bir alanda kullanılır.

MongoDB Go Driver, Go programlarının MongoDB ile iletişim kurmasını sağlayan resmi ve en çok tercih edilen kütüphanedir. Bu sürücü, MongoDB’nin tüm özelliklerini Go dilinin idiomatik yapısıyla kullanmanıza imkan tanır.

MongoDB Go Driver Kurulumu

MongoDB Go Driver’ı projenize dahil etmek oldukça basittir. Go modüllerini kullanıyorsanız, aşağıdaki komutu terminalinizde çalıştırarak sürücüyü indirebilirsiniz:

go get go.mongodb.org/mongo-driver/mongo

Bu komut, sürücüyü ve bağımlılıklarını go.mod dosyanıza ekleyecektir.

MongoDB Bağlantısı Kurma

MongoDB ile etkileşim kurmanın ilk adımı, veritabanına bir bağlantı kurmaktır. Bu, mongo.Connect fonksiyonu ile yapılır. Bağlantı için genellikle bir URI (Uniform Resource Identifier) kullanılır. Yerel bir MongoDB örneği için varsayılan URI genellikle mongodb://localhost:27017 şeklindedir.

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

func main() {
	// Bağlantı URI'si
	clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")

	// Bağlantı kurma
	client, err := mongo.Connect(context.TODO(), clientOptions)
	if err != nil {
		log.Fatal(err)
	}

	// Bağlantıyı kontrol etme
	err = client.Ping(context.TODO(), nil)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("MongoDB'ye başarıyla bağlandı!")

	// Bağlantıyı kapatma (uygulama sonlandığında)
	defer func() {
		if err = client.Disconnect(context.TODO()); err != nil {
			log.Fatal(err)
		}
	}()

	// Bu noktada client nesnesi ile veritabanı işlemleri yapabilirsiniz.
	// Örnek olarak, belirli bir veritabanına erişim:
	database := client.Database("myDatabase")
	collection := database.Collection("myCollection")

	fmt.Printf("'%s' veritabanına ve '%s' koleksiyonuna erişim sağlandı.\n", database.Name(), collection.Name())
}

Bu kod parçacığında:

* context.TODO(): Herhangi bir özel bağlam bilgisi gerekmeyen yerlerde kullanılır. Gerçek uygulamalarda, istek süresi dolduğunda veya iptal edildiğinde bağlantıyı yönetmek için context.WithTimeout veya context.WithCancel gibi daha gelişmiş bağlamlar kullanılmalıdır.
* options.Client().ApplyURI(): MongoDB bağlantı URI’sini ayarlamak için kullanılır.
* mongo.Connect(): Belirtilen seçeneklerle yeni bir MongoDB istemcisi oluşturur.
* client.Ping(): MongoDB sunucusuyla iletişim kurup kuramadığını kontrol eder.
* client.Disconnect(): Uygulama sonlandığında bağlantıyı güvenli bir şekilde kapatır. defer anahtar kelimesi, fonksiyonun sonuna doğru bu işlemin otomatik olarak çalışmasını sağlar.

### Veri Modeli ve Structlar

MongoDB belgelerini Go’da temsil etmek için genellikle struct’lar kullanılır. MongoDB Go Driver, BSON ve Go struct’ları arasında otomatik dönüşüm yapabilir. Struct alanlarını MongoDB’deki alanlara eşleştirmek için bson etiketi kullanılır. Özellikle MongoDB’nin varsayılan _id alanını Go struct’ınızda temsil ederken primitive.ObjectID tipini kullanmanız gerekir.

package main

import (
	"time"

	"go.mongodb.org/mongo-driver/bson/primitive"
)

// User struct'ı MongoDB'deki bir kullanıcı belgesini temsil eder.
type User struct {
	ID        primitive.ObjectID bson:"_id,omitempty" // MongoDB'nin otomatik ürettiği ID
	Name      string             bson:"name"
	Email     string             bson:"email"
	Age       int                bson:"age,omitempty" // Yaş alanı opsiyonel olabilir
	CreatedAt time.Time          bson:"created_at"
}

* bson:"_id,omitempty": Bu etiket, struct’ın ID alanını MongoDB’deki _id alanına eşler. omitempty seçeneği, bu alan boşsa (varsayılan sıfır değeri) BSON çıktısına dahil edilmeyeceğini belirtir. Bu, yeni belgeler oluştururken MongoDB’nin kendi _id‘sini üretmesine olanak tanır.
* bson:"name", bson:"email", bson:"age,omitempty", bson:"created_at": Diğer alanları da MongoDB belgelerindeki karşılıklarına eşler.

### Temel CRUD İşlemleri

MongoDB Go Driver ile veritabanında temel veri işlemleri (oluşturma, okuma, güncelleme, silme) oldukça kolaydır.

#### Belge Ekleme (Create)

Yeni bir belge eklemek için InsertOne veya InsertMany metodları kullanılır.

// Örnek User belgesi
newUser := User{
	Name:      "Ahmet Yılmaz",
	Email:     "ahmet.yilmaz@example.com",
	Age:       30,
	CreatedAt: time.Now(),
}

// Belgeyi koleksiyona ekleme
insertResult, err := collection.InsertOne(context.TODO(), newUser)
if err != nil {
	log.Fatal(err)
}

fmt.Printf("Yeni belge eklendi. ID: %v\n", insertResult.InsertedID)

* InsertOne: Tek bir belgeyi ekler. InsertOneResult döner.
* InsertMany: Birden çok belgeyi toplu olarak ekler. InsertManyResult döner.

#### Belge Okuma (Read)

Belge okuma işlemleri için FindOne ve Find metodları kullanılır.

##### Tek Bir Belge Okuma (FindOne)

Belirli bir kritere uyan ilk belgeyi almak için FindOne kullanılır.

// Belirli bir kullanıcıyı email ile bulma
var foundUser User
filter := bson.M{"email": "ahmet.yilmaz@example.com"} // Sorgu filtresi

err = collection.FindOne(context.TODO(), filter).Decode(&foundUser)
if err == mongo.ErrNoDocuments {
	fmt.Println("Kullanıcı bulunamadı")
} else if err != nil {
	log.Fatal(err)
} else {
	fmt.Printf("Bulunan kullanıcı: %+v\n", foundUser)
}

* bson.M: MongoDB sorgu filtrelerini oluşturmak için kullanılan bir harita türüdür.
* Decode(): Alınan BSON belgesini Go struct’ına çözümler.

##### Birden Çok Belge Okuma (Find)

Belirli kriterlere uyan tüm belgeleri almak için Find kullanılır. Bu metod bir imleç (cursor) döndürür.

// Tüm kullanıcıları listeleme (yaşı 25'ten büyük olanlar)
filter := bson.M{"age": bson.M{"$gt": 25}} // Yaşı 25'ten büyük olanlar
cursor, err := collection.Find(context.TODO(), filter)
if err != nil {
	log.Fatal(err)
}
defer cursor.Close(context.TODO()) // İmleci kapatmayı unutmayın

var users []User
for cursor.Next(context.TODO()) {
	var elem User
	err := cursor.Decode(&elem)
	if err != nil {
		log.Fatal(err)
	}
	users = append(users, elem)
}

if err := cursor.Err(); err != nil {
	log.Fatal(err)
}

fmt.Printf("Yaşı 25'ten büyük kullanıcılar: %d\n", len(users))
for _, user := range users {
	fmt.Printf("- %s (%s)\n", user.Name, user.Email)
}

* cursor.Next(): İmleçte bir sonraki belge varsa true döndürür.
* cursor.Decode(): Mevcut belgeyi bir Go struct’ına çözer.
* cursor.Err(): İmleç sırasında herhangi bir hata olup olmadığını kontrol eder.

#### Belge Güncelleme (Update)

Belgeleri güncellemek için UpdateOne ve UpdateMany metodları kullanılır.

// Belirli bir kullanıcının yaşını güncelleme
filter := bson.M{"email": "ahmet.yilmaz@example.com"}
update := bson.M{"$set": bson.M{"age": 31}} // Yaşı 31 olarak ayarla

updateResult, err := collection.UpdateOne(context.TODO(), filter, update)
if err != nil {
	log.Fatal(err)
}

fmt.Printf("Güncellenen belge sayısı: %v\n", updateResult.ModifiedCount)

* $set: MongoDB’nin bir güncelleme operatörüdür. Belirtilen alanların değerini günceller.
* UpdateOne: Kriterlere uyan ilk belgeyi günceller.
* UpdateMany: Kriterlere uyan tüm belgeleri günceller.

Güncelleme operatörleri hakkında daha fazla bilgi için MongoDB dokümantasyonuna başvurabilirsiniz (örneğin, $inc, $unset, $push, $pull vb.).

#### Belge Silme (Delete)

Belgeleri silmek için DeleteOne ve DeleteMany metodları kullanılır.

// Belirli bir kullanıcıyı email ile silme
filter := bson.M{"email": "ahmet.yilmaz@example.com"}

deleteResult, err := collection.DeleteOne(context.TODO(), filter)
if err != nil {
	log.Fatal(err)
}

fmt.Printf("Silinen belge sayısı: %v\n", deleteResult.DeletedCount)

* DeleteOne: Kriterlere uyan ilk belgeyi siler.
* DeleteMany: Kriterlere uyan tüm belgeleri siler.

### İndeksleme

Performanslı sorgular için veritabanında indeksler oluşturmak kritik öneme sahiptir. MongoDB Go Driver ile indeks oluşturmak ve yönetmek mümkündür.

// Kullanıcı koleksiyonu için email alanına indeks oluşturma
indexModel := mongo.IndexModel{
	Keys: bson.D{{"email", 1}}, // 1 artan sıralama, -1 azalan sıralama
	Options: &options.IndexOptions{
		Unique: mongo.Bool(true), // Emailin benzersiz olmasını sağla
	},
}

// İndeks oluşturma
indexName, err := collection.Indexes().CreateOne(context.TODO(), indexModel)
if err != nil {
	log.Fatal(err)
}

fmt.Printf("İndeks oluşturuldu: %s\n", indexName)

* bson.D: Sıralı anahtar-değer çiftlerini temsil eder. İndeksleme için alan sıralaması önemlidir.
* Keys: İndeks oluşturulacak alanları belirtir. 1 artan, -1 azalan sıralama anlamına gelir.
* Options: İndeks için ek seçenekler (örneğin, benzersizlik, TTL – Time To Live).

### Sorgu Operatörleri ve Filtreler

MongoDB, karmaşık sorguları desteklemek için zengin bir sorgu operatörleri setine sahiptir. Go Driver ile bu operatörleri bson.M veya bson.D kullanarak kullanabilirsiniz.

Bazı yaygın operatörler:

* $eq: Eşit
* $ne: Eşit değil
* $gt: Büyüktür
* $gte: Büyük veya eşittir
* $lt: Küçüktür
* $lte: Küçük veya eşittir
* $in: Değerlerden biriyle eşleşir
* $nin: Değerlerden hiçbiriyle eşleşmez
* $regex: Düzenli ifade eşleşmesi

Örnek: Belirli bir adı içeren ve yaşı 20 ile 40 arasında olan kullanıcıları bulma.

filter := bson.M{
	"name": bson.M{"$regex": "Ahmet", "$options": "i"}, // "Ahmet" ile başlayan (büyük/küçük harf duyarsız)
	"age": bson.M{
		"$gte": 20,
		"$lte": 40,
	},
}

// ... Find işlemi ...

* $options: "i": Büyük/küçük harf duyarsız eşleştirme için kullanılır.

### Toplama Çerçevesi (Aggregation Framework)

MongoDB’nin toplama çerçevesi, veriler üzerinde karmaşık veri işleme ve analizleri yapmanızı sağlar. Go Driver ile toplama işlemleri Aggregate metodu ile gerçekleştirilir. Toplama işlemleri, bir dizi aşamadan (pipeline) oluşur.

Örnek: Kullanıcıları yaş gruplarına göre gruplandırıp ortalama yaşı hesaplama.

// Toplama pipeline'ı
pipeline := []bson.M{
	{
		"$group": bson.M{
			"_id": bson.M{
				"ageGroup": bson.M{
					"$concat": []interface{}{
						bson.M{"$toString": bson.M{"$floor": bson.M{"$divide": []interface{}{"$age", 10}}}},
						"-",
						bson.M{"$toString": bson.M{"$add": []interface{}{bson.M{"$floor": bson.M{"$divide": []interface{}{"$age", 10}}}, 1}}},
						"0",
					},
				},
			},
			"averageAge": bson.M{"$avg": "$age"},
			"count":      bson.M{"$sum": 1},
		},
	},
	{
		"$sort": bson.M{"_id.ageGroup": 1}, // Yaş grubuna göre sırala
	},
}

// Toplama işlemini gerçekleştirme
cursor, err := collection.Aggregate(context.TODO(), pipeline)
if err != nil {
	log.Fatal(err)
}
defer cursor.Close(context.TODO())

// Sonuçları işleme
var results []bson.M
if err = cursor.All(context.TODO(), &results); err != nil {
	log.Fatal(err)
}

for _, result := range results {
	fmt.Printf("Yaş Grubu: %v, Ortalama Yaş: %.2f, Sayı: %v\n", result["_id"], result["averageAge"], result["count"])
}

Bu örnek, MongoDB’nin toplama çerçevesinin gücünü ve Go ile nasıl entegre edildiğini göstermektedir. $group, $sort, $project, $match gibi birçok aşama mevcuttur.

### Hata Yönetimi

Go’da hata yönetimi, error tipinin kullanılmasıyla yapılır. MongoDB Go Driver’daki tüm operasyonlar, bir hata oluştuğunda error tipinde bir değer döndürür. Bu hataları kontrol etmek ve uygun şekilde yönetmek önemlidir.

Önemli hata türlerinden bazıları:

* mongo.ErrNoDocuments: Sorgu sonucunda hiçbir belge bulunamadığında döner.
* mongo.ErrDuplicateKey: Benzersiz bir alan üzerine tekrar veri eklenmeye çalışıldığında döner.
* mongo.ErrTimeout: İşlem belirlenen süre içinde tamamlanamadığında döner.

Bağlantı hataları, sorgu hataları ve veri işleme hataları gibi tüm olası durumları if err != nil blokları ile kontrol etmelisiniz.

### Bağlantı Havuzları (Connection Pooling)

MongoDB Go Driver, bağlantıları otomatik olarak yöneten yerleşik bir bağlantı havuzu özelliğine sahiptir. Bu, her istek için yeni bir bağlantı kurmak yerine mevcut bağlantıları yeniden kullanarak performansı artırır. Bağlantı havuzu seçenekleri options.ClientOptions ile ayarlanabilir.

clientOptions := options.Client().ApplyURI("mongodb://localhost:27017").SetMinPoolSize(5).SetMaxPoolSize(20)
client, err := mongo.Connect(context.TODO(), clientOptions)
// ...

### Context Kullanımı

Go’nun context paketi, isteklerin yaşam döngüsünü yönetmek, zaman aşımlarını ayarlamak ve iptal sinyallerini iletmek için kullanılır. MongoDB Go Driver’daki tüm operasyonlar ilk parametre olarak bir context.Context alır. Bu, uzun süren sorguların veya işlemlerin iptal edilmesini sağlar.

ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel() // Fonksiyon çıkışında cancel fonksiyonunu çağırarak bağlamın serbest bırakılmasını sağla

// Bağlantı kurma
client, err := mongo.Connect(ctx, clientOptions)
if err != nil {
	log.Fatal(err)
}
// ... diğer işlemler ...

### Güvenlik

MongoDB bağlantılarınızı güvence altına almak önemlidir.

* Kimlik Doğrulama: MongoDB sunucunuzda kimlik doğrulama etkinse, bağlantı URI’nize kullanıcı adı ve şifre eklemelisiniz: mongodb://user:password@host:port.
* SSL/TLS: Veri şifrelemesi için SSL/TLS kullanın. options.Client().SetTLSConfig() ile SSL/TLS ayarlarını yapılandırabilirsiniz.
* Yetkilendirme: Kullanıcıların yalnızca ihtiyaç duydukları verilere erişebilmesi için rol tabanlı erişim kontrolü uygulayın.

### Sonuç

MongoDB Go Driver, Go programlarının MongoDB ile güçlü ve verimli bir şekilde etkileşim kurmasını sağlayan kapsamlı bir araçtır. Bu makalede, kurulumdan temel CRUD işlemlerine, indekslemeden toplama çerçevesine kadar birçok önemli konuyu ele aldık. Bağlantı yönetimi, hata işleme ve güvenlik gibi konulara dikkat ederek, sağlam ve ölçeklenebilir uygulamalar geliştirebilirsiniz. MongoDB’nin esnek veri modeli ve Go’nun performansı ile birleşimi, modern uygulama geliştirme ihtiyaçları için mükemmel bir uyum sunar. Geliştirdiğiniz projelerde bu rehberden yararlanarak MongoDB ve Go’yu etkin bir şekilde kullanabilirsiniz.