mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-04-29 03:06:35 -05:00
Code Issues Packages Projects Releases 159 Wiki Activity

Apply suggestions from code review

Browse Source 
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
This commit is contained in:
Aaron Son
2026-02-09 13:01:07 -08:00
committed by GitHub
parent 78d1391ef2
commit 32eca34587
1 changed files with 5 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
integration-tests/go-sql-server-driver/concurrent_writes_test.go
+5 -21
View File
@@ -26,7 +26,7 @@ import (
driver "github.com/dolthub/dolt/go/libraries/doltcore/dtestutils/sql_server_driver"
)
// The txLocks in
// TestConcurrentWrites verifies concurrent write behavior and transaction locking in the SQL server driver.
func TestConcurrentWrites(t *testing.T) {
t.Parallel()
var ports DynamicResources
@@ -125,27 +125,11 @@ func TestConcurrentWrites(t *testing.T) {
defer func () {
require.NoError(t, conn.Close())
}()
rows, err := conn.QueryContext(ctx, "SELECT COUNT(*) FROM data")
if err != nil {
require.NoError(t, err)
}
var i int
for rows.Next() {
err = rows.Scan(&i)
require.NoError(t, err)
}
require.NoError(t, rows.Err())
require.NoError(t, rows.Close())
err = conn.QueryRowContext(ctx, "SELECT COUNT(*) FROM data").Scan(&i)
require.NoError(t, err)
t.Logf("read %d", i)
rows, err = conn.QueryContext(ctx, "SELECT COUNT(*) FROM dolt_log")
if err != nil {
require.NoError(t, err)
}
for rows.Next() {
err = rows.Scan(&i)
require.NoError(t, err)
}
require.NoError(t, rows.Err())
require.NoError(t, rows.Close())
err = conn.QueryRowContext(ctx, "SELECT COUNT(*) FROM dolt_log").Scan(&i)
require.NoError(t, err)
t.Logf("created %d commits", i)
}