forked from mirror/gorm
Add Debug Mode
This commit is contained in:
parent
6ac0012879
commit
94bd2eb8d5
16
chain.go
16
chain.go
|
@ -12,6 +12,7 @@ import (
|
||||||
type Chain struct {
|
type Chain struct {
|
||||||
db *sql.DB
|
db *sql.DB
|
||||||
driver string
|
driver string
|
||||||
|
debug bool
|
||||||
value interface{}
|
value interface{}
|
||||||
|
|
||||||
Errors []error
|
Errors []error
|
||||||
|
@ -27,10 +28,20 @@ type Chain struct {
|
||||||
unscoped bool
|
unscoped bool
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *Chain) msg(str string) {
|
||||||
|
if s.debug {
|
||||||
|
debug(str)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (s *Chain) err(err error) error {
|
func (s *Chain) err(err error) error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
s.Errors = append(s.Errors, err)
|
s.Errors = append(s.Errors, err)
|
||||||
s.Error = err
|
s.Error = err
|
||||||
|
|
||||||
|
if s.debug {
|
||||||
|
debug(err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -206,6 +217,11 @@ func (s *Chain) Table(name string) *Chain {
|
||||||
return s
|
return s
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *Chain) Debug() *Chain {
|
||||||
|
s.debug = true
|
||||||
|
return s
|
||||||
|
}
|
||||||
|
|
||||||
func (s *Chain) validSql(str string) (result bool) {
|
func (s *Chain) validSql(str string) (result bool) {
|
||||||
result = regexp.MustCompile("^\\s*[\\w][\\w\\s,.]*[\\w]\\s*$").MatchString(str)
|
result = regexp.MustCompile("^\\s*[\\w][\\w\\s,.]*[\\w]\\s*$").MatchString(str)
|
||||||
if !result {
|
if !result {
|
||||||
|
|
|
@ -48,6 +48,7 @@ func init() {
|
||||||
panic(fmt.Sprintf("No error should happen when connect database, but got %+v", err))
|
panic(fmt.Sprintf("No error should happen when connect database, but got %+v", err))
|
||||||
}
|
}
|
||||||
db.SetPool(10)
|
db.SetPool(10)
|
||||||
|
db.DebugMode = true
|
||||||
|
|
||||||
err = db.Exec("drop table users;").Error
|
err = db.Exec("drop table users;").Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
7
main.go
7
main.go
|
@ -5,6 +5,7 @@ import "database/sql"
|
||||||
type DB struct {
|
type DB struct {
|
||||||
db *sql.DB
|
db *sql.DB
|
||||||
driver string
|
driver string
|
||||||
|
DebugMode bool
|
||||||
}
|
}
|
||||||
|
|
||||||
func Open(driver, source string) (db DB, err error) {
|
func Open(driver, source string) (db DB, err error) {
|
||||||
|
@ -18,7 +19,7 @@ func (s *DB) SetPool(n int) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *DB) buildChain() *Chain {
|
func (s *DB) buildChain() *Chain {
|
||||||
return &Chain{db: s.db, driver: s.driver}
|
return &Chain{db: s.db, driver: s.driver, debug: s.DebugMode}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *DB) Where(querystring interface{}, args ...interface{}) *Chain {
|
func (s *DB) Where(querystring interface{}, args ...interface{}) *Chain {
|
||||||
|
@ -81,6 +82,10 @@ func (s *DB) Table(name string) *Chain {
|
||||||
return s.buildChain().Table(name)
|
return s.buildChain().Table(name)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *DB) Debug() *Chain {
|
||||||
|
return s.buildChain().Debug()
|
||||||
|
}
|
||||||
|
|
||||||
func (s *DB) CreateTable(value interface{}) *Chain {
|
func (s *DB) CreateTable(value interface{}) *Chain {
|
||||||
return s.buildChain().CreateTable(value)
|
return s.buildChain().CreateTable(value)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue