revert postgres package refactor (#1796)

* Revert "refactor: move postgres to pg package (#1781)"

This reverts commit ba8ac974aa.

* remove pg, use postgres
master
Kevin Wan 3 years ago committed by GitHub
parent cb4fcf2c6c
commit 5d4e7c84ee
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -65,7 +65,8 @@ type (
// NewTimingWheel returns a TimingWheel. // NewTimingWheel returns a TimingWheel.
func NewTimingWheel(interval time.Duration, numSlots int, execute Execute) (*TimingWheel, error) { func NewTimingWheel(interval time.Duration, numSlots int, execute Execute) (*TimingWheel, error) {
if interval <= 0 || numSlots <= 0 || execute == nil { if interval <= 0 || numSlots <= 0 || execute == nil {
return nil, fmt.Errorf("interval: %v, slots: %d, execute: %p", interval, numSlots, execute) return nil, fmt.Errorf("interval: %v, slots: %d, execute: %p",
interval, numSlots, execute)
} }
return newTimingWheelWithClock(interval, numSlots, execute, timex.NewTicker(interval)) return newTimingWheelWithClock(interval, numSlots, execute, timex.NewTicker(interval))

@ -1,14 +0,0 @@
package pg
import (
// imports the driver, don't remove this comment, golint requires.
_ "github.com/lib/pq"
"github.com/zeromicro/go-zero/core/stores/sqlx"
)
const postgresDriverName = "postgres"
// New returns a postgres connection.
func New(datasource string, opts ...sqlx.SqlOption) sqlx.SqlConn {
return sqlx.NewSqlConn(postgresDriverName, datasource, opts...)
}

@ -1,11 +0,0 @@
package pg
import (
"testing"
"github.com/stretchr/testify/assert"
)
func TestPostgreSql(t *testing.T) {
assert.NotNil(t, New("postgre"))
}

@ -1,7 +1,14 @@
package postgres package postgres
import "github.com/zeromicro/go-zero/core/stores/pg" import (
// imports the driver, don't remove this comment, golint requires.
_ "github.com/lib/pq"
"github.com/zeromicro/go-zero/core/stores/sqlx"
)
// New creates a new postgresql store. const postgresDriverName = "postgres"
// Deprecated: use pg.New instead.
var New = pg.New // New returns a postgres connection.
func New(datasource string, opts ...sqlx.SqlOption) sqlx.SqlConn {
return sqlx.NewSqlConn(postgresDriverName, datasource, opts...)
}

Loading…
Cancel
Save