File tree Expand file tree Collapse file tree 8 files changed +34
-33
lines changed Expand file tree Collapse file tree 8 files changed +34
-33
lines changed Original file line number Diff line number Diff line change @@ -10,9 +10,6 @@ import:
10
10
- package : github.com/mgutz/jo
11
11
subpackages :
12
12
- v1
13
- - package : github.com/mgutz/logxi
14
- subpackages :
15
- - v1
16
13
- package : github.com/mgutz/str
17
14
- package : github.com/pmylund/go-cache
18
15
- package : github.com/satori/go.uuid
@@ -22,4 +19,4 @@ import:
22
19
- package : gopkg.in/stretchr/testify.v1
23
20
subpackages :
24
21
- assert
25
-
22
+ - package : github.com/mgutz/logxi
Original file line number Diff line number Diff line change @@ -4,10 +4,10 @@ import (
4
4
"fmt"
5
5
"strconv"
6
6
7
- "github.com/mgutz/logxi/v1 "
7
+ "github.com/mgutz/logxi"
8
8
)
9
9
10
- var logger log .Logger
10
+ var logger logxi .Logger
11
11
12
12
// Strict tells dat to raise errors
13
13
var Strict = false
@@ -53,5 +53,5 @@ func init() {
53
53
identifierTab [i ] = fmt .Sprintf ("dat%d" , i )
54
54
}
55
55
56
- logger = log .New ("dat" )
56
+ logger = logxi .New ("dat" )
57
57
}
Original file line number Diff line number Diff line change 1
1
package kvs
2
2
3
- import (
4
- "github.com/mgutz/logxi/v1"
5
- )
3
+ import "github.com/mgutz/logxi"
6
4
7
- var logger log .Logger
5
+ var logger logxi .Logger
8
6
9
7
func init () {
10
- logger = log .New ("dat.cache" )
8
+ logger = logxi .New ("dat.cache" )
11
9
}
Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ package runner
2
2
3
3
import (
4
4
"database/sql"
5
- "log"
6
5
7
6
"github.com/jmoiron/sqlx"
8
7
"gopkg.in/mgutz/dat.v1"
@@ -36,10 +35,10 @@ func pgMustNotAllowEscapeSequence(conn *DB) {
36
35
}
37
36
38
37
if standardConformingStrings != "on" {
39
- log . Fatalf ("Database allows escape sequences. Cannot be used with interpolation. " +
38
+ logger . Fatal ("Database allows escape sequences. Cannot be used with interpolation. " +
40
39
"standard_conforming_strings=%q\n " +
41
40
"See http://www.postgresql.org/docs/9.3/interactive/sql-syntax-lexical.html#SQL-SYNTAX-STRINGS-ESCAPE" ,
42
- standardConformingStrings )
41
+ "standardConformingStrings" , standardConformingStrings )
43
42
}
44
43
}
45
44
Original file line number Diff line number Diff line change @@ -5,13 +5,13 @@ import (
5
5
"time"
6
6
7
7
"github.com/cenkalti/backoff"
8
- "github.com/mgutz/logxi/v1 "
8
+ "github.com/mgutz/logxi"
9
9
"gopkg.in/mgutz/dat.v1"
10
10
"gopkg.in/mgutz/dat.v1/kvs"
11
11
"gopkg.in/mgutz/dat.v1/postgres"
12
12
)
13
13
14
- var logger log .Logger
14
+ var logger logxi .Logger
15
15
16
16
// LogQueriesThreshold is the threshold for logging "slow" queries
17
17
var LogQueriesThreshold time.Duration
@@ -21,7 +21,7 @@ var LogErrNoRows bool
21
21
22
22
func init () {
23
23
dat .Dialect = postgres .New ()
24
- logger = log .New ("dat:sqlx" )
24
+ logger = logxi .New ("dat:sqlx" )
25
25
}
26
26
27
27
// Cache caches query results.
Original file line number Diff line number Diff line change 7
7
"os"
8
8
"time"
9
9
10
- "github.com/mgutz/logxi/v1 "
10
+ "github.com/mgutz/logxi"
11
11
12
12
"gopkg.in/mgutz/dat.v1"
13
13
"gopkg.in/mgutz/dat.v1/kvs"
@@ -22,7 +22,7 @@ func init() {
22
22
sqlDB = realDb ()
23
23
testDB = NewDB (sqlDB , "postgres" )
24
24
dat .Strict = false
25
- log .Suppress (true )
25
+ logxi .Suppress (true )
26
26
27
27
Cache = kvs .NewMemoryKeyValueStore (1 * time .Second )
28
28
//Cache, _ = kvs.NewDefaultRedisStore()
Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ package runner
2
2
3
3
import (
4
4
"errors"
5
- "log"
6
5
"sync"
7
6
"time"
8
7
@@ -138,7 +137,7 @@ func (tx *Tx) AutoCommit() error {
138
137
if err != nil {
139
138
tx .state = txErred
140
139
if dat .Strict {
141
- log . Fatalf ("Could not commit transaction: %s \n " , err . Error () )
140
+ logger . Fatal ("Could not commit transaction" , "err" , err )
142
141
}
143
142
tx .popState ()
144
143
return logger .Error ("transaction.AutoCommit.commit_error" , err )
@@ -163,7 +162,7 @@ func (tx *Tx) AutoRollback() error {
163
162
if err != nil {
164
163
tx .state = txErred
165
164
if dat .Strict {
166
- log . Fatalf ("Could not rollback transaction: %s \n " , err . Error () )
165
+ logger . Fatal ("Could not rollback transaction" , "err" , err )
167
166
}
168
167
tx .popState ()
169
168
return logger .Error ("transaction.AutoRollback.rollback_error" , err )
You can’t perform that action at this time.
0 commit comments