db

package

v0.0.0-...-0150db3 Latest Latest Go to latest Published: Dec 13, 2017 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jodezer/ezorm

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func EnsureAllIndex()
func GetCol(dbName, col string) (session *mgo.Session, collection *mgo.Collection)
func IsFinishInit() bool
func IsMgoDup(err error) bool
func IsMgoNotFound(err error) bool
func MustNewMgoSessions(config *MongoConfig) []*mgo.Session
func MysqlExec(query string, args ...interface{}) (sql.Result, error)
func MysqlInit(cfg *MysqlConfig)
func MysqlQuery(query string, args ...interface{}) (*sql.Rows, error)
func NewCollection(session *mgo.Session, dbName, name string) *mgo.Collection
func NewObjectId() bson.ObjectId
func NewSession() (session *mgo.Session)
func ObjectIds(ids []string) (ret []bson.ObjectId)
func SetOnEnsureIndex(f func())
func SetOnFinishInit(f func())
func Setup(c *MongoConfig)
func ShareSession() *mgo.Session
func TimeFormat(t time.Time) string
func TimeParse(s string) time.Time
func TimeParseLocalTime(s string) time.Time
func TimeToLocalTime(c time.Time) string
type M
- func In(ids []string) M
- func InID(ids []string) (ret M)
- func (m M) Update(qs ...M) M
type MongoConfig
type Mysql
- func GetMysql() *Mysql
- func NewMysql(cfg *MysqlConfig) (*Mysql, error)
type MysqlConfig
type QueryWrapper
type Queryer
type RedisStore
- func NewRedisStore(host string, port int, password string, db int) (*RedisStore, error)
- func (r *RedisStore) StringScan(str string, val interface{}) error
type SqlServer
- func GetSqlServer(dataSourceName string) *SqlServer
- func (s *SqlServer) AddQueryWrapper(wrapper QueryWrapper)
- func (s *SqlServer) Exec(query string, args ...interface{}) (sql.Result, error)
- func (s *SqlServer) Query(dest interface{}, query string, args ...interface{}) error

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrOperaBeforeInit = errors.New("please set db.SetOnFinishInit when needed operating db in init()")

Functions ¶

func EnsureAllIndex ¶

func EnsureAllIndex()

func GetCol ¶

func GetCol(dbName, col string) (session *mgo.Session, collection *mgo.Collection)

func IsFinishInit ¶

func IsFinishInit() bool

func IsMgoDup ¶

func IsMgoDup(err error) bool

func IsMgoNotFound ¶

func IsMgoNotFound(err error) bool

func MustNewMgoSessions ¶

func MustNewMgoSessions(config *MongoConfig) []*mgo.Session

func MysqlExec ¶

func MysqlExec(query string, args ...interface{}) (sql.Result, error)

func MysqlInit ¶

func MysqlInit(cfg *MysqlConfig)

func MysqlQuery ¶

func MysqlQuery(query string, args ...interface{}) (*sql.Rows, error)

func NewCollection ¶

func NewCollection(session *mgo.Session, dbName, name string) *mgo.Collection

func NewObjectId ¶

func NewObjectId() bson.ObjectId

func NewSession ¶

func NewSession() (session *mgo.Session)

func ObjectIds ¶

func ObjectIds(ids []string) (ret []bson.ObjectId)

func SetOnEnsureIndex ¶

func SetOnEnsureIndex(f func())

func SetOnFinishInit ¶

func SetOnFinishInit(f func())

func Setup ¶

func Setup(c *MongoConfig)

func ShareSession ¶

func ShareSession() *mgo.Session

func TimeFormat ¶

func TimeFormat(t time.Time) string

func TimeParse ¶

func TimeParse(s string) time.Time

func TimeParseLocalTime ¶

func TimeParseLocalTime(s string) time.Time

func TimeToLocalTime ¶

func TimeToLocalTime(c time.Time) string

Types ¶

type M ¶

type M bson.M

func In ¶

func In(ids []string) M

func InID ¶

func InID(ids []string) (ret M)

func (M) Update ¶

func (m M) Update(qs ...M) M

type MongoConfig ¶

type MongoConfig struct {
	MongoDB   string
	DBName    string
	PoolLimit int
}

type Mysql ¶

type Mysql struct {
	*sql.DB
	// contains filtered or unexported fields
}

func GetMysql ¶

func GetMysql() *Mysql

func NewMysql ¶

func NewMysql(cfg *MysqlConfig) (*Mysql, error)

type MysqlConfig ¶

type MysqlConfig struct {
	DataSource      string
	PoolSize        int
	ConnMaxLifeTime time.Duration
}

type QueryWrapper ¶

type QueryWrapper func(queryer Queryer, query string, args ...interface{}) Queryer

type Queryer ¶

type Queryer func(query string, args ...interface{}) (interface{}, error)

type RedisStore ¶

type RedisStore struct {
	redis.Cmdable
}

func NewRedisStore ¶

func NewRedisStore(host string, port int, password string, db int) (*RedisStore, error)

func (*RedisStore) StringScan ¶

func (r *RedisStore) StringScan(str string, val interface{}) error

! functions

type SqlServer ¶

type SqlServer struct {
	*sqlx.DB
	// contains filtered or unexported fields
}

func GetSqlServer ¶

func GetSqlServer(dataSourceName string) *SqlServer

func (*SqlServer) AddQueryWrapper ¶

func (s *SqlServer) AddQueryWrapper(wrapper QueryWrapper)

func (*SqlServer) Exec ¶

func (s *SqlServer) Exec(query string, args ...interface{}) (sql.Result, error)

func (*SqlServer) Query ¶

func (s *SqlServer) Query(dest interface{}, query string, args ...interface{}) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL