mirror of
https://github.com/aljazceru/turso.git
synced 2026-02-02 23:04:23 +01:00
remove TestTransactions that was being skipped. added back in second PR
This commit is contained in:
@@ -320,70 +320,6 @@ func TestVectorOperations(t *testing.T) {
|
||||
fmt.Printf("Extracted vector: %s\n", extracted)
|
||||
}
|
||||
|
||||
func TestTransactions(t *testing.T) {
|
||||
t.Skip("Skipping transaction tests - transactions not yet implemented in the limbo driver")
|
||||
|
||||
db, err := sql.Open("sqlite3", ":memory:")
|
||||
if err != nil {
|
||||
t.Fatalf("Error opening connection: %v", err)
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
// Create test table
|
||||
_, err = db.Exec(`CREATE TABLE tx_test (id INTEGER PRIMARY KEY, value TEXT)`)
|
||||
if err != nil {
|
||||
t.Fatalf("Error creating table: %v", err)
|
||||
}
|
||||
|
||||
// Test successful transaction
|
||||
tx, err := db.Begin()
|
||||
if err != nil {
|
||||
t.Fatalf("Error beginning transaction: %v", err)
|
||||
}
|
||||
|
||||
_, err = tx.Exec(`INSERT INTO tx_test VALUES (1, 'before commit')`)
|
||||
if err != nil {
|
||||
t.Fatalf("Error executing in transaction: %v", err)
|
||||
}
|
||||
|
||||
err = tx.Commit()
|
||||
if err != nil {
|
||||
t.Fatalf("Error committing transaction: %v", err)
|
||||
}
|
||||
|
||||
// Verify commit worked
|
||||
var value string
|
||||
err = db.QueryRow(`SELECT value FROM tx_test WHERE id = 1`).Scan(&value)
|
||||
if err != nil {
|
||||
t.Fatalf("Error querying after commit: %v", err)
|
||||
}
|
||||
if value != "before commit" {
|
||||
t.Fatalf("Expected 'before commit', got '%s'", value)
|
||||
}
|
||||
|
||||
// Test rollback
|
||||
tx, err = db.Begin()
|
||||
if err != nil {
|
||||
t.Fatalf("Error beginning transaction: %v", err)
|
||||
}
|
||||
|
||||
_, err = tx.Exec(`INSERT INTO tx_test VALUES (2, 'should rollback')`)
|
||||
if err != nil {
|
||||
t.Fatalf("Error executing in transaction: %v", err)
|
||||
}
|
||||
|
||||
err = tx.Rollback()
|
||||
if err != nil {
|
||||
t.Fatalf("Error rolling back transaction: %v", err)
|
||||
}
|
||||
|
||||
// Verify rollback worked
|
||||
err = db.QueryRow(`SELECT value FROM tx_test WHERE id = 2`).Scan(&value)
|
||||
if err == nil {
|
||||
t.Fatalf("Expected error after rollback, got value: %s", value)
|
||||
}
|
||||
}
|
||||
|
||||
func TestSQLFeatures(t *testing.T) {
|
||||
db, err := sql.Open("sqlite3", ":memory:")
|
||||
if err != nil {
|
||||
|
||||
Reference in New Issue
Block a user