sql

package

v0.1.1 Latest Latest Go to latest Published: Jan 4, 2020 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Fs02/rel

Links

Open Source Insights

Documentation ¶

Overview ¶

Package sql is general sql adapter that wraps database/sql.

Index ¶

Variables
func ExtractString(s, left, right string) string
type Adapter
- func New(config *Config) *Adapter
type Buffer
- func (b *Buffer) Append(args ...interface{})
- func (b *Buffer) Reset()
type Builder
- func NewBuilder(config *Config) *Builder
type Config
type Cursor
- func (c *Cursor) Fields() ([]string, error)
- func (c *Cursor) NopScanner() interface{}

Constants ¶

This section is empty.

Variables ¶

View Source

var UnescapeCharacter byte = '^'

UnescapeCharacter disable field escaping when it starts with this character.

Functions ¶

func ExtractString ¶

func ExtractString(s, left, right string) string

ExtractString between two string.

Types ¶

type Adapter ¶

type Adapter struct {
	Config *Config
	DB     *sql.DB
	Tx     *sql.Tx
	// contains filtered or unexported fields
}

Adapter definition for mysql database.

func New ¶

func New(config *Config) *Adapter

New initialize adapter without db.

func (*Adapter) Aggregate ¶

func (adapter *Adapter) Aggregate(query rel.Query, mode string, field string, loggers ...rel.Logger) (int, error)

Aggregate record using given query.

func (*Adapter) Begin ¶

func (adapter *Adapter) Begin() (rel.Adapter, error)

Begin begins a new transaction.

func (*Adapter) Close ¶

func (adapter *Adapter) Close() error

Close mysql connection.

func (*Adapter) Commit ¶

func (adapter *Adapter) Commit() error

Commit commits current transaction.

func (*Adapter) Delete ¶

func (adapter *Adapter) Delete(query rel.Query, loggers ...rel.Logger) error

Delete deletes all results that match the query.

func (*Adapter) Exec ¶

func (adapter *Adapter) Exec(statement string, args []interface{}, loggers ...rel.Logger) (int64, int64, error)

Exec performs exec operation.

func (*Adapter) Insert ¶

func (adapter *Adapter) Insert(query rel.Query, changes rel.Changes, loggers ...rel.Logger) (interface{}, error)

Insert inserts a record to database and returns its id.

func (*Adapter) InsertAll ¶

func (adapter *Adapter) InsertAll(query rel.Query, fields []string, allchanges []rel.Changes, loggers ...rel.Logger) ([]interface{}, error)

InsertAll inserts all record to database and returns its ids.

func (*Adapter) Query ¶

func (adapter *Adapter) Query(query rel.Query, loggers ...rel.Logger) (rel.Cursor, error)

Query performs query operation.

func (*Adapter) Rollback ¶

func (adapter *Adapter) Rollback() error

Rollback revert current transaction.

func (*Adapter) Update ¶

func (adapter *Adapter) Update(query rel.Query, changes rel.Changes, loggers ...rel.Logger) error

Update updates a record in database.

type Buffer ¶

type Buffer struct {
	bytes.Buffer
	Arguments []interface{}
}

Buffer used to strings buffer and argument of the query.

func (*Buffer) Append ¶

func (b *Buffer) Append(args ...interface{})

Append argumetns.

func (*Buffer) Reset ¶

func (b *Buffer) Reset()

Reset buffer.

type Builder ¶

type Builder struct {
	// contains filtered or unexported fields
}

Builder defines information of query b.

func NewBuilder ¶

func NewBuilder(config *Config) *Builder

NewBuilder create new SQL builder.

func (*Builder) Aggregate ¶

func (b *Builder) Aggregate(query rel.Query, mode string, field string) (string, []interface{})

Aggregate generates query for aggregation.

func (*Builder) Delete ¶

func (b *Builder) Delete(table string, filter rel.FilterQuery) (string, []interface{})

Delete generates query for delete.

func (*Builder) Find ¶

func (b *Builder) Find(query rel.Query) (string, []interface{})

Find generates query for select.

func (*Builder) Insert ¶

func (b *Builder) Insert(table string, changes rel.Changes) (string, []interface{})

Insert generates query for insert.

func (*Builder) InsertAll ¶

func (b *Builder) InsertAll(table string, fields []string, allchanges []rel.Changes) (string, []interface{})

InsertAll generates query for multiple insert.

func (*Builder) Returning ¶

func (b *Builder) Returning(field string) *Builder

Returning append returning to insert rel.

func (*Builder) Update ¶

func (b *Builder) Update(table string, changes rel.Changes, filter rel.FilterQuery) (string, []interface{})

Update generates query for update.

type Config ¶

type Config struct {
	Placeholder         string
	Ordinal             bool
	InsertDefaultValues bool
	EscapeChar          string
	ErrorFunc           func(error) error
	IncrementFunc       func(Adapter) int
}

Config holds configuration for adapter.

type Cursor ¶

type Cursor struct {
	*sql.Rows
}

Cursor used for retrieving result.

func (*Cursor) Fields ¶

func (c *Cursor) Fields() ([]string, error)

Fields returned in the result.

func (*Cursor) NopScanner ¶

func (c *Cursor) NopScanner() interface{}

NopScanner for this adapter.

Source Files ¶

View all Source files

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