sqldb

Documentation

Index

• Variables
• type Base
  • func (b *Base) CreateSqlModel(d *sqlutil.Dialect) error
  • func (b *Base) CreateTables(d *Dialect) error
  • func (b *Base) Expire(expire time.Time) error
  • func (b *Base) InsertGoupMapping(group []byte, num int64, msgid []byte, expire time.Time) error
  • func (b *Base) InsertIDMapping(msgid, bucket []byte, expire time.Time) error
  • func (b *Base) QueryGroupList(group []byte, first, last int64, ...) error
  • func (b *Base) QueryGroupMapping(group []byte, num int64) (msgid, bucket bufferex.Binary, err error)
  • func (b *Base) QueryGroupShift(group []byte, num int64, backward bool) (nxt int64, msgid bufferex.Binary, err error)
  • func (b *Base) QueryIDMapping(msgid []byte) (bucket bufferex.Binary, err error)
• type Dialect

Variables

var MsSqlDialect = &Dialect{
	Binary: "varbinary",
	Int64:  "bigint",
	Date:   "date",
}

Microsoft SQL Server (untested)

var PgDialect = &Dialect{
	Binary: "bytea",
	Int64:  "bigint",
	Date:   "date",
}

PostgreSQL

Types

type Base

type Base struct {
	DB *sql.DB
}

func (*Base) CreateSqlModel

func (b *Base) CreateSqlModel(d *sqlutil.Dialect) error

func (*Base) CreateTables

func (b *Base) CreateTables(d *Dialect) error

func (*Base) Expire

func (b *Base) Expire(expire time.Time) error

func (*Base) InsertGoupMapping

func (b *Base) InsertGoupMapping(group []byte, num int64, msgid []byte, expire time.Time) error

func (*Base) InsertIDMapping

func (b *Base) InsertIDMapping(msgid, bucket []byte, expire time.Time) error

func (*Base) QueryGroupList

func (b *Base) QueryGroupList(group []byte, first, last int64, targ func(num int64, bucket, msgid bufferex.Binary)) error

func (*Base) QueryGroupMapping

func (b *Base) QueryGroupMapping(group []byte, num int64) (msgid, bucket bufferex.Binary, err error)

func (*Base) QueryGroupShift

func (b *Base) QueryGroupShift(group []byte, num int64, backward bool) (nxt int64, msgid bufferex.Binary, err error)

func (*Base) QueryIDMapping

func (b *Base) QueryIDMapping(msgid []byte) (bucket bufferex.Binary, err error)

type Dialect

type Dialect struct {
	Binary, Int64, Date string
}