


Apabila bekerja dengan pangkalan data SQL dalam Go, memastikan atomicity dan menguruskan rollback semasa transaksi berbilang langkah boleh menjadi mencabar. Dalam artikel ini, saya akan membimbing anda membuat rangka kerja yang teguh, boleh diguna semula dan boleh diuji untuk melaksanakan transaksi SQL dalam Go, menggunakan generik untuk fleksibiliti.
Kami akan membina utiliti SqlWriteExec untuk melaksanakan berbilang operasi pangkalan data bergantung dalam transaksi. Ia menyokong kedua-dua operasi tanpa status dan stateful, membolehkan aliran kerja yang canggih seperti memasukkan entiti berkaitan sambil menguruskan kebergantungan dengan lancar.
Mengapa Kita Memerlukan Rangka Kerja untuk Transaksi SQL?
Dalam aplikasi dunia nyata, operasi pangkalan data jarang diasingkan. Pertimbangkan senario ini:
Memasukkan pengguna dan mengemas kini inventori mereka secara atom.
Membuat pesanan dan memproses pembayarannya, memastikan ketekalan.
Dengan berbilang langkah yang terlibat, mengurus pemulangan semasa kegagalan menjadi penting untuk memastikan integriti data.
Bekerja dengan go in Txn management.
Jika anda menulis pangkalan data txn mungkin terdapat beberapa plat dandang yang mungkin anda perlu pertimbangkan sebelum menulis logik teras. Walaupun pengurusan txn ini diuruskan oleh spring boot di java dan anda tidak pernah mempedulikan mereka semasa menulis kod dalam java tetapi ini tidak berlaku dalam golang. Contoh mudah disediakan di bawah
func basicTxn(db *sql.DB) error { // start a transaction tx, err := db.Begin() if err != nil { return err } defer func() { if r := recover(); r != nil { tx.Rollback() } else if err != nil { tx.Rollback() } else { tx.Commit() } }() // insert data into the orders table _, err = tx.Exec("INSERT INTO orders (id, customer_name, order_date) VALUES (1, 'John Doe', '2022-01-01')") if err != nil { return err } return nil }
Kami tidak boleh mengharapkan untuk mengulangi kod rollback/commit untuk setiap fungsi. Kami mempunyai dua pilihan di sini sama ada mencipta kelas yang akan menyediakan fungsi sebagai jenis pulangan yang apabila dilaksanakan dalam penangguhan akan melakukan/mengembalikan txn atau mencipta kelas pembalut yang akan membungkus semua fungsi txn bersama-sama dan melaksanakan sekali gus.
Saya menggunakan pilihan kemudian dan perubahan dalam kod boleh dilihat di bawah.
func TestSqlWriteExec_CreateOrderTxn(t *testing.T) { db := setupDatabase() // create a new SQL Write Executor err := dbutils.NewSqlTxnExec[OrderRequest, OrderProcessingResponse](context.TODO(), db, nil, &OrderRequest{CustomerName: "CustomerA", ProductID: 1, Quantity: 10}). StatefulExec(InsertOrder). StatefulExec(UpdateInventory). StatefulExec(InsertShipment). Commit() // check if the transaction was committed successfully if err != nil { t.Fatal(err) return } verifyTransactionSuccessful(t, db) t.Cleanup( func() { cleanup(db) db.Close() }, ) }
func InsertOrder(ctx context.Context, txn *sql.Tx, order *OrderRequest, orderProcessing *OrderProcessingResponse) error { // Insert Order result, err := txn.Exec("INSERT INTO orders (customer_name, product_id, quantity) VALUES (, , )", order.CustomerName, order.ProductID, order.Quantity) if err != nil { return err } // Get the inserted Order ID orderProcessing.OrderID, err = result.LastInsertId() return err } func UpdateInventory(ctx context.Context, txn *sql.Tx, order *OrderRequest, orderProcessing *OrderProcessingResponse) error { // Update Inventory if it exists and the quantity is greater than the quantity check if it exists result, err := txn.Exec("UPDATE inventory SET product_quantity = product_quantity - WHERE id = AND product_quantity >= ", order.Quantity, order.ProductID) if err != nil { return err } // Get the number of rows affected rowsAffected, err := result.RowsAffected() if rowsAffected == 0 { return errors.New("Insufficient inventory") } return err } func InsertShipment(ctx context.Context, txn *sql.Tx, order *OrderRequest, orderProcessing *OrderProcessingResponse) error { // Insert Shipment result, err := txn.Exec("INSERT INTO shipping_info (customer_name, shipping_address) VALUES (, 'Shipping Address')", order.CustomerName) if err != nil { return err } // Get the inserted Shipping ID orderProcessing.ShippingID, err = result.LastInsertId() return err }
Kod ini akan menjadi lebih tepat dan ringkas.
Bagaimana logik teras dilaksanakan
Ideanya adalah untuk mengasingkan txn kepada satu struct go supaya ia boleh menerima berbilang txn. Dengan txn yang saya maksudkan fungsi yang akan melakukan tindakan dengan txn yang kami buat untuk kelas.
type TxnFn[T any] func(ctx context.Context, txn *sql.Tx, processingReq *T) error type StatefulTxnFn[T any, R any] func(ctx context.Context, txn *sql.Tx, processingReq *T, processedRes *R) error
Kedua-dua ini adalah jenis fungsi yang akan mengambil txn untuk memproses sesuatu. Kini dalam lapisan data melaksanakan cipta fungsi seperti ini dan hantarkannya kepada kelas pelaksana yang menguruskan menyuntik args dan melaksanakan fungsi.
// SQL Write Executor is responsible when executing write operations // For dependent writes you may need to add the dependent data to processReq and proceed to the next function call type SqlTxnExec[T any, R any] struct { db *sql.DB txn *sql.Tx txnFns []TxnFn[T] statefulTxnFns []StatefulTxnFn[T, R] processingReq *T processedRes *R ctx context.Context err error }
Di sinilah kami menyimpan semua butiran txn_fn dan kami akan mempunyai kaedah Commit() untuk mencuba melakukan txn.
func (s *SqlTxnExec[T, R]) Commit() (err error) { defer func() { if p := recover(); p != nil { s.txn.Rollback() panic(p) } else if err != nil { err = errors.Join(err, s.txn.Rollback()) } else { err = errors.Join(err, s.txn.Commit()) } return }() for _, writeFn := range s.txnFns { if err = writeFn(s.ctx, s.txn, s.processingReq); err != nil { return } } for _, statefulWriteFn := range s.statefulTxnFns { if err = statefulWriteFn(s.ctx, s.txn, s.processingReq, s.processedRes); err != nil { return } } return }
Anda boleh mendapatkan lebih banyak contoh dan ujian dalam repo -
https://github.com/mahadev-k/go-utils/tree/main/examples
Walaupun kami berat sebelah terhadap sistem teragih dan protokol konsensus pada masa kini, kami masih menggunakan sql dan ia masih wujud.
Beri tahu saya jika sesiapa ingin menyumbang dan membina di atas perkara ini!!
Terima kasih kerana membaca sejauh ini!!
https://in.linkedin.com/in/mahadev-k-934520223
https://x.com/mahadev_k_
Atas ialah kandungan terperinci Membina Perlaksanaan Transaksi SQL yang Teguh dalam Go dengan Rangka Kerja Generik. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Artikel ini menerangkan cara menggunakan alat PPROF untuk menganalisis prestasi GO, termasuk membolehkan profil, mengumpul data, dan mengenal pasti kesesakan biasa seperti CPU dan isu memori.

Artikel ini membincangkan ujian unit menulis di GO, meliputi amalan terbaik, teknik mengejek, dan alat untuk pengurusan ujian yang cekap.

Artikel ini menunjukkan penciptaan dan stub di GO untuk ujian unit. Ia menekankan penggunaan antara muka, menyediakan contoh pelaksanaan mengejek, dan membincangkan amalan terbaik seperti menjaga mocks fokus dan menggunakan perpustakaan penegasan. Articl

OpenSSL, sebagai perpustakaan sumber terbuka yang digunakan secara meluas dalam komunikasi yang selamat, menyediakan algoritma penyulitan, kunci dan fungsi pengurusan sijil. Walau bagaimanapun, terdapat beberapa kelemahan keselamatan yang diketahui dalam versi sejarahnya, yang sebahagiannya sangat berbahaya. Artikel ini akan memberi tumpuan kepada kelemahan umum dan langkah -langkah tindak balas untuk OpenSSL dalam sistem Debian. Debianopenssl yang dikenal pasti: OpenSSL telah mengalami beberapa kelemahan yang serius, seperti: Kerentanan Pendarahan Jantung (CVE-2014-0160): Kelemahan ini mempengaruhi OpenSSL 1.0.1 hingga 1.0.1f dan 1.0.2 hingga 1.0.2 versi beta. Penyerang boleh menggunakan kelemahan ini untuk maklumat sensitif baca yang tidak dibenarkan di pelayan, termasuk kunci penyulitan, dll.

Artikel ini meneroka kekangan jenis adat Go untuk generik. Ia memperincikan bagaimana antara muka menentukan keperluan jenis minimum untuk fungsi generik, meningkatkan keselamatan jenis dan kebolehgunaan semula kod. Artikel ini juga membincangkan batasan dan amalan terbaik

Artikel ini membincangkan pakej GO's Reflect, yang digunakan untuk manipulasi kod runtime, bermanfaat untuk siri, pengaturcaraan generik, dan banyak lagi. Ia memberi amaran tentang kos prestasi seperti pelaksanaan yang lebih perlahan dan penggunaan memori yang lebih tinggi, menasihati penggunaan yang bijak dan terbaik

Artikel ini membincangkan menggunakan ujian yang didorong oleh jadual di GO, satu kaedah yang menggunakan jadual kes ujian untuk menguji fungsi dengan pelbagai input dan hasil. Ia menyoroti faedah seperti kebolehbacaan yang lebih baik, penurunan duplikasi, skalabiliti, konsistensi, dan a

Artikel ini meneroka menggunakan alat pengesanan untuk menganalisis aliran pelaksanaan aplikasi GO. Ia membincangkan teknik instrumentasi manual dan automatik, membandingkan alat seperti Jaeger, Zipkin, dan OpenTelemetry, dan menonjolkan visualisasi data yang berkesan


Alat AI Hot

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool
Gambar buka pakaian secara percuma

Clothoff.io
Penyingkiran pakaian AI

AI Hentai Generator
Menjana ai hentai secara percuma.

Artikel Panas

Alat panas

Penyesuai Pelayan SAP NetWeaver untuk Eclipse
Integrasikan Eclipse dengan pelayan aplikasi SAP NetWeaver.

PhpStorm versi Mac
Alat pembangunan bersepadu PHP profesional terkini (2018.2.1).

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

MantisBT
Mantis ialah alat pengesan kecacatan berasaskan web yang mudah digunakan yang direka untuk membantu dalam pengesanan kecacatan produk. Ia memerlukan PHP, MySQL dan pelayan web. Lihat perkhidmatan demo dan pengehosan kami.

VSCode Windows 64-bit Muat Turun
Editor IDE percuma dan berkuasa yang dilancarkan oleh Microsoft