sqlite

package

v0.0.9 Latest Latest Go to latest Published: Sep 25, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

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

Repository

github.com/litesql/ha

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddSQLChange(conn *sqlite3.SQLiteConn, sql string, args []any) error
func Backup(ctx context.Context, dsn string, memory bool, w io.Writer) error
func Deserialize(ctx context.Context, file string) error
func DeserializeFromReader(ctx context.Context, r io.Reader) error
func Filename(ctx context.Context) (string, error)
func RegisterDriver(extensions []string, name string, pub CDCPublisher)
func RemoveLastChange(conn *sqlite3.SQLiteConn) error
func SetGlobalDB(database *sql.DB)
type CDCPublisher
type Change
type ChangeSet
- func NewChangeSet(node string) *ChangeSet
- func (cs *ChangeSet) AddChange(change Change)
- func (cs *ChangeSet) Apply() error
- func (cs *ChangeSet) Clear()
- func (cs *ChangeSet) Send(pub CDCPublisher) error
type Request
type Response
- func Exec(ctx context.Context, conn *sql.Conn, eq execerQuerier, stmt *Statement, ...) (*Response, error)
- func Transaction(ctx context.Context, req []Request) ([]*Response, error)
type Statement
- func NewStatement(ctx context.Context, sql string) (*Statement, error)
- func (s *Statement) Begin() bool
- func (s *Statement) Columns() []string
- func (s *Statement) Commit() bool
- func (s *Statement) DDL() bool
- func (s *Statement) HasDistinct() bool
- func (s *Statement) HasReturning() bool
- func (s *Statement) IsCreateTable() bool
- func (s *Statement) IsDelete() bool
- func (s *Statement) IsExplain() bool
- func (s *Statement) IsInsert() bool
- func (s *Statement) IsSelect() bool
- func (s *Statement) IsUpdate() bool
- func (s *Statement) Parameters() []string
- func (s *Statement) Rollback() bool
- func (s *Statement) Source() string
- func (s *Statement) Type() string

Constants ¶

View Source

const (
	TypeExplain            = "EXPLAIN"
	TypeSelect             = "SELECT"
	TypeInsert             = "INSERT"
	TypeUpdate             = "UPDATE"
	TypeDelete             = "DELETE"
	TypeCreateTable        = "CREATE TABLE"
	TypeCreateIndex        = "CREATE INDEX"
	TypeCreateView         = "CREATE VIEW"
	TypeCreateTrigger      = "CREATE TRIGGER"
	TypeCreateVirtualTable = "CREATE VIRTUAL TABLE"
	TypeAlterTable         = "ALTER TABLE"
	TypeVacuum             = "VACUUM"
	TypeDrop               = "DROP"
	TypeAnalyze            = "ANALYZE"
	TypeBegin              = "BEGIN"
	TypeCommit             = "COMMIT"
	TypeRollback           = "ROLLBACK"
	TypeSavepoint          = "SAVEPOINT"
	TypeRelease            = "RELEASE"
	TypeOther              = "OTHER"
)

Variables ¶

View Source

var (
	ErrInvalidSQL = fmt.Errorf("invalid SQL")
)

Functions ¶

func AddSQLChange ¶ added in v0.0.7

func AddSQLChange(conn *sqlite3.SQLiteConn, sql string, args []any) error

func Backup ¶ added in v0.0.7

func Backup(ctx context.Context, dsn string, memory bool, w io.Writer) error

func Deserialize ¶ added in v0.0.2

func Deserialize(ctx context.Context, file string) error

func DeserializeFromReader ¶ added in v0.0.9

func DeserializeFromReader(ctx context.Context, r io.Reader) error

func Filename ¶ added in v0.0.9

func Filename(ctx context.Context) (string, error)

func RegisterDriver ¶

func RegisterDriver(extensions []string, name string, pub CDCPublisher)

func RemoveLastChange ¶ added in v0.0.7

func RemoveLastChange(conn *sqlite3.SQLiteConn) error

func SetGlobalDB ¶

func SetGlobalDB(database *sql.DB)

Types ¶

type CDCPublisher ¶

type CDCPublisher interface {
	Publish(cs *ChangeSet) error
}

type Change ¶

type Change struct {
	Database  string   `json:"database,omitempty"`
	Table     string   `json:"table,omitempty"`
	Columns   []string `json:"columns,omitempty"`
	Operation string   `json:"operation"` // "INSERT", "UPDATE", "DELETE", "SQL"
	OldRowID  int64    `json:"old_rowid,omitempty"`
	NewRowID  int64    `json:"new_rowid,omitempty"`
	OldValues []any    `json:"old_values,omitempty"`
	NewValues []any    `json:"new_values,omitempty"`
	SQL       string   `json:"sql,omitempty"`
	SQLArgs   []any    `json:"sql_args,omitempty"`
}

type ChangeSet ¶

type ChangeSet struct {
	Node      string   `json:"node"`
	ProcessID int64    `json:"process_id"`
	Changes   []Change `json:"changes"`
	Timestamp int64    `json:"timestamp_ns"`
}

func NewChangeSet ¶

func NewChangeSet(node string) *ChangeSet

func (*ChangeSet) AddChange ¶

func (cs *ChangeSet) AddChange(change Change)

func (*ChangeSet) Apply ¶

func (cs *ChangeSet) Apply() error

func (*ChangeSet) Clear ¶

func (cs *ChangeSet) Clear()

func (*ChangeSet) Send ¶

func (cs *ChangeSet) Send(pub CDCPublisher) error

type Request ¶

type Request struct {
	Sql    string         `json:"sql"`
	Params map[string]any `json:"params"`
}

type Response ¶

type Response struct {
	Columns      []string `json:"columns"`
	Rows         [][]any  `json:"rows"`
	RowsAffected int64    `json:"-"`
	NoReturning  bool     `json:"-"`
}

func Exec ¶

func Exec(ctx context.Context, conn *sql.Conn, eq execerQuerier, stmt *Statement, params map[string]any) (*Response, error)

func Transaction ¶

func Transaction(ctx context.Context, req []Request) ([]*Response, error)

type Statement ¶

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

func NewStatement ¶

func NewStatement(ctx context.Context, sql string) (*Statement, error)

func (*Statement) Begin ¶

func (s *Statement) Begin() bool

func (*Statement) Columns ¶

func (s *Statement) Columns() []string

func (*Statement) Commit ¶

func (s *Statement) Commit() bool

func (*Statement) DDL ¶

func (s *Statement) DDL() bool

func (*Statement) HasDistinct ¶

func (s *Statement) HasDistinct() bool

func (*Statement) HasReturning ¶

func (s *Statement) HasReturning() bool

func (*Statement) IsCreateTable ¶

func (s *Statement) IsCreateTable() bool

func (*Statement) IsDelete ¶

func (s *Statement) IsDelete() bool

func (*Statement) IsExplain ¶

func (s *Statement) IsExplain() bool

func (*Statement) IsInsert ¶

func (s *Statement) IsInsert() bool

func (*Statement) IsSelect ¶

func (s *Statement) IsSelect() bool

func (*Statement) IsUpdate ¶

func (s *Statement) IsUpdate() bool

func (*Statement) Parameters ¶

func (s *Statement) Parameters() []string

func (*Statement) Rollback ¶

func (s *Statement) Rollback() bool

func (*Statement) Source ¶

func (s *Statement) Source() string

func (*Statement) Type ¶

func (s *Statement) Type() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
parser

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