Skip to content

Commit 6aa5aaa

Browse files
authored
Merge pull request #105 from closetool/master
fix: improve log support
2 parents 40a8c16 + e5dd073 commit 6aa5aaa

File tree

2 files changed

+21
-0
lines changed

2 files changed

+21
-0
lines changed

adapter.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,11 @@ import (
2626
"github.com/jackc/pgconn"
2727
"gorm.io/driver/mysql"
2828
"gorm.io/driver/postgres"
29+
2930
//"gorm.io/driver/sqlite"
3031
"gorm.io/driver/sqlserver"
3132
"gorm.io/gorm"
33+
"gorm.io/gorm/logger"
3234
)
3335

3436
const (
@@ -278,6 +280,11 @@ func (a *Adapter) open() error {
278280
return a.createTable()
279281
}
280282

283+
// AddLogger adds logger to db
284+
func (a *Adapter) AddLogger(l logger.Interface) {
285+
a.db = a.db.Session(&gorm.Session{Logger: l, Context: a.db.Statement.Context})
286+
}
287+
281288
func (a *Adapter) close() error {
282289
a.db = nil
283290
return nil

adapter_test.go

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ package gormadapter
1616

1717
import (
1818
"log"
19+
"os"
1920
"testing"
2021

2122
"github.com/casbin/casbin/v2"
@@ -27,6 +28,7 @@ import (
2728
"gorm.io/driver/mysql"
2829
"gorm.io/driver/postgres"
2930
"gorm.io/gorm"
31+
"gorm.io/gorm/logger"
3032
)
3133

3234
func testGetPolicy(t *testing.T, e *casbin.Enforcer, res [][]string) {
@@ -428,7 +430,19 @@ func TestAdapters(t *testing.T) {
428430
testUpdatePolicies(t, a)
429431
testUpdateFilteredPolicies(t, a)
430432

433+
a = initAdapter(t, "mysql", "root:@tcp(127.0.0.1:3306)/", "casbin", "casbin_rule")
434+
a.AddLogger(logger.New(log.New(os.Stdout, "\r\n", log.LstdFlags), logger.Config{}))
435+
testUpdatePolicy(t, a)
436+
testUpdatePolicies(t, a)
437+
testUpdateFilteredPolicies(t, a)
438+
439+
a = initAdapter(t, "postgres", "user=postgres password=postgres host=127.0.0.1 port=5432 sslmode=disable")
440+
testUpdatePolicy(t, a)
441+
testUpdatePolicies(t, a)
442+
testUpdateFilteredPolicies(t, a)
443+
431444
a = initAdapter(t, "postgres", "user=postgres password=postgres host=127.0.0.1 port=5432 sslmode=disable")
445+
a.AddLogger(logger.New(log.New(os.Stdout, "\r\n", log.LstdFlags), logger.Config{}))
432446
testUpdatePolicy(t, a)
433447
testUpdatePolicies(t, a)
434448
testUpdateFilteredPolicies(t, a)

0 commit comments

Comments
 (0)