added github workflow

Author: samitani

.github/workflows/test.yaml

@@ -0,0 +1,20 @@
+on: [push, pull_request]
+name: Test
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Install Go
+        uses: actions/setup-go@v4
+        with:
+          go-version: '^1.21.0'
+      - name: Checkout code
+        uses: actions/checkout@v3
+      - uses: actions/cache@v3
+        with:
+          path: ~/go/pkg/mod
+          key: ${{ runner.os }}-go-${{ hashFiles('**/go.sum') }}
+          restore-keys: |
+            ${{ runner.os }}-go-
+      - name: Test
+        run: go test -coverprofile=coverage.txt -covermode=atomic -race ./...

Makefile

@@ -9,4 +9,4 @@ lint:
 
 .PHONY: test
 test:
-	go test -v ./...
+	go test -coverprofile=coverage.txt -covermode=atomic -v -race ./...

benchmark/spanner_oltp.go

@@ -15,8 +15,8 @@ import (
 
 const (
 	stmtSpannerPointSelects     = "SELECT c FROM sbtest%d WHERE id=@Id"
-	stmtSpannerSimpleRanges     = "SELECT c FROM sbtest%d WHERE id BETWEEN %d AND %d"
-	stmtSpannerSumRanges        = "SELECT SUM(k) FROM sbtest%d WHERE id BETWEEN %d AND %d"
+	stmtSpannerSimpleRanges     = "SELECT c FROM sbtest%d WHERE id BETWEEN @Begin AND @End"
+	stmtSpannerSumRanges        = "SELECT SUM(k) FROM sbtest%d WHERE id BETWEEN @Begin AND @End"
 	stmtSpannerOrderRanges      = "SELECT c FROM sbtest%d WHERE id BETWEEN %d AND %d ORDER BY c"
 	stmtSpannerDistinctRanges   = "SELECT DISTINCT c FROM sbtest%d WHERE id BETWEEN %d AND %d ORDER BY c"
 	stmtSpannerIndexUpdates     = "UPDATE sbtest%d SET k=k+1 WHERE id=%d"
@@ -80,6 +80,19 @@ func (s *SpannerOLTP) Event(ctx context.Context) (reads uint64, writes uint64, o
 			}
 			numReads += 1
 		}
+		for i := 0; i < numSimpleRanges; i++ {
+			begin := sbRand(0, s.opts.TableSize)
+			stmt := spanner.Statement{
+				SQL:    fmt.Sprintf(stmtSpannerSimpleRanges, tableNum),
+				Params: map[string]interface{}{"Begin": begin, "End": begin + rangeSize - 1},
+			}
+			_, err := txn.Query(ctx, stmt).Next()
+			if err != nil && err != iterator.Done {
+				return err
+			}
+			numReads += 1
+		}
+
 		return nil
 	})
 	return numReads, 0, 0, 0, err

cmd/go-sysbench/main.go

@@ -2,20 +2,27 @@ package main
 
 // TODO
 // 1. Spanner Session Pool の様子を観測する
-// 2. パフォーマンス差分を埋める
-//   2-2. thread fairness の計算
-// 3. SSL/ON OFF
+// 2. Spannerのパラメータクエリが有効化できていることを確認する
+// 3. SpannerのBIT_REVERSEを試す
+// 4. Spannerのシナリオの作成
+// 5. SpannerでDeadlineexceeded
 
-// 5. Spannerのシナリオの作成
-//   5-2. PostgreSQL の DSN のエスケープ
-//   5-3. 空振りクエリはotherにカウントする
-//   5-4. Spannerのパラメータクエリが有効化できていることを確認する
+// 10. パフォーマンス差分を埋める
+// 11. thread fairness の計算
 
-// 6. 乱数生成をクエリを投げる前段階で行う
-// 11. PreparedStatement の実装
+// 20. SSL/ON OFF
 
-// 7. README を書く
-// 10. カスタムシナリオを書く
+// 31. PostgreSQL の DSN のエスケープ
+// 32. 空振りクエリはotherにカウントする
+
+// 41. 乱数生成をクエリを投げる前段階で行う
+// 42. PreparedStatement の実装
+
+// 51. カスタムシナリオを書く
+
+// 60. --mysql-ignore-errors のサポート
+
+// 70. README を書く
 
 import (
 	"log"

runner/histogram_test.go

@@ -2,7 +2,6 @@ package runner
 
 import (
 	"testing"
-	// "fmt"
 )
 
 func TestHistogramAdd(t *testing.T) {
@@ -43,16 +42,3 @@ func TestGetPercentile(t *testing.T) {
 		t.Errorf("Expected 100th percentile to be 99999.0, got %f", p100)
 	}
 }
-
-func TestPrint(t *testing.T) {
-	h := NewHistogram(1024, 0.001, 100000)
-
-	h.Add(0.002)
-	h.Add(0.01)
-	h.Add(0.01)
-	h.Add(1.0)
-	h.Add(500.0)
-	h.Add(99999.0)
-
-	h.Print()
-}