Geliştiriciler için ai-mysql

ai-mysql oxmysql’in API’sini birebir (imzalar, callback kuralları, sonuç şekilleri) cevaplar; bu yüzden oxmysql’in kendi dokümantasyonu geçerlidir. Bu sayfa neyi cevapladığını ve önemli ayrıntıları listeler.

Lua’dan kullanmakCopy Anchor Link

oxmysql’in sarmalayıcısını yükle; yol ai-mysql’e çözülür:

server_script '@oxmysql/lib/MySQL.lua'

-- Sonucu bekler: bir thread ya da event handler içinde çağır.
local row = MySQL.single.await('SELECT money FROM my_accounts WHERE owner = ?', { identifier })

-- Callback biçimi: beklemez.
MySQL.update('UPDATE my_accounts SET money = money - ? WHERE owner = ? AND money >= ?', { 100, identifier, 100 }, function(affected)
    if affected == 1 then print('paid') end
end)

Export’larCopy Anchor Link

Her export server tarafındadır ve exports['ai-mysql'] ile exports.oxmysql altında cevap verir. Her biri (query, params?, callback?) alır:

• query: ? yer tutucuları ya da adlandırılmış @name / :name yer tutucularıyla SQL metni.
• params: ? için bir dizi, adlandırılmış yer tutucular için bir nesne. Verilmeyebilir; o zaman callback ikinci argüman olabilir.
• callback: sonuçla çağrılır. O olmadan da çağrı çalışır.

Her export’un ayrıca bir promise biçimi vardır: <name>_async ve <name>Sync (query_async(query, params) hata olunca reddedilen bir Promise döndürür).

transactionCopy Anchor Link

Birden çok ifadeyi tek bir bağlantıda çalıştırır; ya hepsi başarılı olur ya hiçbiri.

Taraf: Server · Bekler: hayır (callback üzerinden cevap verir; transaction_async bir Promise döndürür)

transaction(queries: Array<string | [string, unknown[] | object] | { query: string; values?: unknown[] | object; parameters?: unknown[] | object }>, params?: unknown[] | object, cb?: (committed: boolean) => void): void

local ok = MySQL.transaction.await({
    { query = 'UPDATE my_accounts SET money = money - ? WHERE owner = ?', values = { 100, from } },
    { query = 'UPDATE my_accounts SET money = money + ? WHERE owner = ?', values = { 100, to } },
})

ParametrelerCopy Anchor Link

Dönüş değeriCopy Anchor Link

Doğrudan hiçbir şey; callback true ya da false alır. Rollback hatayı konsola yazdırır ve oxmysql:transaction-error event’ini tetikler.

startTransactionCopy Anchor Link

Bir transaction açar ve fonksiyonuna ona bağlı bir query yardımcısı verir. Rollback için fonksiyonundan false döndür. 30 saniye sonra zaman aşımına uğrar.

Taraf: Server · Bekler: evet (Promise)

startTransaction(work: (query: (sql: string, params?: unknown[] | object) => Promise<unknown>) => Promise<boolean | void>): Promise<boolean>

Dönüş değeriCopy Anchor Link

Promise<boolean>: commit edilince true. Fonksiyonun false döndürdüğünde, hata fırlattığında ya da 30 saniye dolduğunda false.

ÖrnekCopy Anchor Link

// @aicore-fivem/mysql olmadan düz bir JavaScript ya da TypeScript resource’u.
const db = exports.oxmysql;

async function pay(from: string, to: string, amount: number): Promise<boolean> {
  return db.startTransaction(async (query: (sql: string, params?: unknown[]) => Promise<any>) => {
    const res = await query("UPDATE my_accounts SET money = money - ? WHERE owner = ? AND money >= ?", [amount, from, amount]);
    if (res.affectedRows !== 1) return false; // para yetmiyor: rollback
    await query("UPDATE my_accounts SET money = money + ? WHERE owner = ?", [amount, to]);
  });
}

Eski export adlarıCopy Anchor Link

Callback ve hata kurallarıCopy Anchor Link

Bunlar oxmysql’i takip eder:

• Başarı: callback sonucu alır.
• Promise biçimiyle (ya da Lua’da .await ile) hata: promise hata metniyle reddedilir.
• Düz callback ile hata: hata konsola yazdırılır ve callback çağrılmaz.

Event’lerCopy Anchor Link

oxmysql:errorCopy Anchor Link

Taraf: Server (yerel) · bir sorgu başarısız olunca tetiklenir.

oxmysql:transaction-errorCopy Anchor Link

Taraf: Server (yerel) · bir transaction rollback olunca tetiklenir. Yük { message: string, resource: string }.

on("oxmysql:error", (e: { query?: string; message: string; resource: string }) => {
  console.log(`[db] ${e.resource}: ${e.message} (${e.query ?? "?"})`);
});