adoquery

Documentation

Index

• type ADOQuery
  • func New(conn Database) *ADOQuery
  • func (ado *ADOQuery) AddError(err error) error
  • func (ado *ADOQuery) Close()
  • func (ADOQuery) GetJsonStr() string
  • func (ADOQuery) GetString(key string) (value string)
  • func (ado *ADOQuery) Open()
  • func (ado *ADOQuery) SQL(sql string, vars ...interface{})
  • func (ado *ADOQuery) ScanRows(rows *sql.Rows)
• type Database
  • func (d *Database) Connect() (err error)
  • func (d *Database) Disconnect()
  • func (d *Database) Query(sql string, value ...any) (rows *sql.Rows, err error)
• type Driver

Types

type ADOQuery

type ADOQuery struct {
	// 数据连接对象
	Database *Database

	// 查询Sql
	Sql string

	// 响应结果
	Json         []byte
	RowsAffected int64
	Error        error
}

func New

func New(conn Database) *ADOQuery

func (*ADOQuery) AddError

func (ado *ADOQuery) AddError(err error) error

func (*ADOQuery) Close

func (ado *ADOQuery) Close()

func (ADOQuery) GetJsonStr

func (ADOQuery) GetJsonStr() string

func (ADOQuery) GetString

func (ADOQuery) GetString(key string) (value string)

func (*ADOQuery) Open

func (ado *ADOQuery) Open()

func (*ADOQuery) SQL

func (ado *ADOQuery) SQL(sql string, vars ...interface{})

func (*ADOQuery) ScanRows

func (ado *ADOQuery) ScanRows(rows *sql.Rows)

type Database

type Database struct {
	// 数据库类型
	Driver Driver
	// 连接字符串
	Path     string
	Port     string
	Username string
	Password string
	Dbname   string
	Config   string
	// contains filtered or unexported fields
}

func (*Database) Connect

func (d *Database) Connect() (err error)

func (*Database) Disconnect

func (d *Database) Disconnect()

func (*Database) Query

func (d *Database) Query(sql string, value ...any) (rows *sql.Rows, err error)

type Driver

type Driver int32

const (
	SQLServer Driver = 1 << (8 - 1 - iota)
	MySql
	Sqlite
	Postgresql
	Oracle
)