Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
mattn committed Jan 18, 2017
1 parent b9e7e69 commit 7ed900a
Show file tree
Hide file tree
Showing 3 changed files with 72 additions and 61 deletions.
60 changes: 0 additions & 60 deletions sqlite3_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -1184,66 +1184,6 @@ func TestFunctionRegistration(t *testing.T) {
}
}

type sumAggregator int64

func (s *sumAggregator) Step(x int64) {
*s += sumAggregator(x)
}

func (s *sumAggregator) Done() int64 {
return int64(*s)
}

func TestAggregatorRegistration(t *testing.T) {
customSum := func() *sumAggregator {
var ret sumAggregator
return &ret
}

sql.Register("sqlite3_AggregatorRegistration", &SQLiteDriver{
ConnectHook: func(conn *SQLiteConn) error {
if err := conn.RegisterAggregator("customSum", customSum, true); err != nil {
return err
}
return nil
},
})
db, err := sql.Open("sqlite3_AggregatorRegistration", ":memory:")
if err != nil {
t.Fatal("Failed to open database:", err)
}
defer db.Close()

_, err = db.Exec("create table foo (department integer, profits integer)")
if err != nil {
// trace feature is not implemented
t.Skip("Failed to create table:", err)
}

_, err = db.Exec("insert into foo values (1, 10), (1, 20), (2, 42)")
if err != nil {
t.Fatal("Failed to insert records:", err)
}

tests := []struct {
dept, sum int64
}{
{1, 30},
{2, 42},
}

for _, test := range tests {
var ret int64
err = db.QueryRow("select customSum(profits) from foo where department = $1 group by department", test.dept).Scan(&ret)
if err != nil {
t.Fatal("Query failed:", err)
}
if ret != test.sum {
t.Fatalf("Custom sum returned wrong value, got %d, want %d", ret, test.sum)
}
}
}

func TestDeclTypes(t *testing.T) {

d := SQLiteDriver{}
Expand Down
72 changes: 72 additions & 0 deletions sqlite3_trace_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,72 @@
// Copyright (C) 2016 Yasuhiro Matsumoto <[email protected]>.
//
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file.
// +build trace

package sqlite3

import (
"database/sql"
"testing"
)

type sumAggregator int64

func (s *sumAggregator) Step(x int64) {
*s += sumAggregator(x)
}

func (s *sumAggregator) Done() int64 {
return int64(*s)
}

func TestAggregatorRegistration(t *testing.T) {
customSum := func() *sumAggregator {
var ret sumAggregator
return &ret
}

sql.Register("sqlite3_AggregatorRegistration", &SQLiteDriver{
ConnectHook: func(conn *SQLiteConn) error {
if err := conn.RegisterAggregator("customSum", customSum, true); err != nil {
return err
}
return nil
},
})
db, err := sql.Open("sqlite3_AggregatorRegistration", ":memory:")
if err != nil {
t.Fatal("Failed to open database:", err)
}
defer db.Close()

_, err = db.Exec("create table foo (department integer, profits integer)")
if err != nil {
// trace feature is not implemented
t.Skip("Failed to create table:", err)
}

_, err = db.Exec("insert into foo values (1, 10), (1, 20), (2, 42)")
if err != nil {
t.Fatal("Failed to insert records:", err)
}

tests := []struct {
dept, sum int64
}{
{1, 30},
{2, 42},
}

for _, test := range tests {
var ret int64
err = db.QueryRow("select customSum(profits) from foo where department = $1 group by department", test.dept).Scan(&ret)
if err != nil {
t.Fatal("Query failed:", err)
}
if ret != test.sum {
t.Fatalf("Custom sum returned wrong value, got %d, want %d", ret, test.sum)
}
}
}
1 change: 0 additions & 1 deletion tracecallback.go
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
// Copyright (C) 2016 Yasuhiro Matsumoto <[email protected]>.
// TODO: add "Gimpl do foo" team?
//
// Use of this source code is governed by an MIT-style
// license that can be found in the LICENSE file.
Expand Down

0 comments on commit 7ed900a

Please sign in to comment.