Skip to content

Commit a4d4b80

Browse files
committed
open mysql
1 parent 9f1101d commit a4d4b80

File tree

3 files changed

+25
-4
lines changed

3 files changed

+25
-4
lines changed

README.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,10 @@ Completed Features:
2424
import (
2525
"database/sql"
2626
"github.com/folospace/go-mysql-orm/orm"
27-
_ "github.com/go-sql-driver/mysql"
2827
)
2928

3029
//connect mysql db
31-
var db, _ = sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/mydb?parseTime=true&charset=utf8mb4&loc=Asia%2FShanghai")
30+
var db, _ = orm.OpenMysql("user:password@tcp(127.0.0.1:3306)/mydb?parseTime=true&charset=utf8mb4&loc=Asia%2FShanghai")
3231

3332
//user table model
3433
var UserTable = orm.NewQuery(User{}, db)

example.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,11 +5,10 @@ import (
55
"errors"
66
"fmt"
77
"github.com/folospace/go-mysql-orm/orm"
8-
_ "github.com/go-sql-driver/mysql"
98
)
109

1110
//connect mysql db
12-
var db, _ = sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/mydb?parseTime=true&charset=utf8mb4&loc=Asia%2FShanghai")
11+
var db, _ = orm.OpenMysql("user:password@tcp(127.0.0.1:3306)/mydb?parseTime=true&charset=utf8mb4&loc=Asia%2FShanghai")
1312

1413
//user table model
1514
var UserTable = orm.NewQuery(User{}, db)

orm/db.go

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
package orm
2+
3+
import (
4+
"database/sql"
5+
sqldriver "database/sql/driver"
6+
_ "github.com/go-sql-driver/mysql"
7+
)
8+
9+
func OpenMysql(dataSourceName string) (*sql.DB, error) {
10+
return sql.Open("mysql", dataSourceName)
11+
}
12+
13+
func Open(driverName, dataSourceName string) (*sql.DB, error) {
14+
return sql.Open(driverName, dataSourceName)
15+
}
16+
17+
func OpenDB(driver sqldriver.Connector) *sql.DB {
18+
return sql.OpenDB(driver)
19+
}
20+
21+
func Register(name string, drvier sqldriver.Driver) {
22+
sql.Register(name, drvier)
23+
}

0 commit comments

Comments
 (0)