store

May 30, 2025

Changes in this version

type Row

+ func NewRowFromColumns(table *Table, cols query.Columns) (Row, error)

+ func NewRowWithResultMap(resultMap map[string]any) Row

Nov 23, 2024

Changes in this version

+ type Store struct

+ func NewStore() *Store

+ func (store *Store) AlterDatabase(conn net.Conn, stmt query.AlterDatabase) error

+ func (store *Store) AlterTable(conn net.Conn, stmt query.AlterTable) error

+ func (store *Store) Begin(conn net.Conn, stmt query.Begin) error

+ func (store *Store) Commit(conn net.Conn, stmt query.Commit) error

+ func (store *Store) CreateDatabase(conn net.Conn, stmt query.CreateDatabase) error

+ func (store *Store) CreateTable(conn net.Conn, stmt query.CreateTable) error

+ func (store *Store) Delete(conn net.Conn, stmt query.Delete) (sql.ResultSet, error)

+ func (store *Store) DropDatabase(conn net.Conn, stmt query.DropDatabase) error

+ func (store *Store) DropTable(conn net.Conn, stmt query.DropTable) error

+ func (store *Store) Insert(conn net.Conn, stmt query.Insert) error

+ func (store *Store) LookupDatabaseTable(conn net.Conn, dbName string, tblName string) (*Database, *Table, error)

+ func (store *Store) Rollback(conn net.Conn, stmt query.Rollback) error

+ func (store *Store) Select(conn net.Conn, stmt query.Select) (sql.ResultSet, error)

+ func (store *Store) SystemSelect(conn net.Conn, stmt query.Select) (sql.ResultSet, error)

+ func (store *Store) Update(conn net.Conn, stmt query.Update) (sql.ResultSet, error)

+ func (store *Store) Use(conn net.Conn, stmt query.Use) error

Nov 16, 2024

Changes in this version

type Database

+ func (db *Database) DatabaseName() string

Oct 27, 2024

Changes in this version

type Database

+ func (db *Database) LookupTable(name string) (*Table, bool)

type Databases

+ func (dbs *Databases) LookupTableWithDatabase(dbName string, tableName string) (*Table, bool)

+ func (dbs Databases) LookupDatabase(name string) (*Database, bool)

type MemStore

+ func (store *MemStore) LookupDatabaseTable(conn postgresql.Conn, dbName string, tblName string) (*Database, *Table, error)

Sep 27, 2023

Changes in this version

type MemStore

+ func (store *MemStore) CopyData(conn *postgresql.Conn, q *query.Copy, stream *postgresql.CopyStream) (message.Responses, error)

+ func (store *MemStore) SystemSelect(conn *postgresql.Conn, q *query.Select) (message.Responses, error)

Sep 17, 2023

Changes in this version

type MemStore

+ func (store *MemStore) AlterDatabase(*postgresql.Conn, *query.AlterDatabase) (message.Responses, error)

+ func (store *MemStore) AlterTable(*postgresql.Conn, *query.AlterTable) (message.Responses, error)

+ func (store *MemStore) Begin(conn *postgresql.Conn, q *query.Begin) (message.Responses, error)

+ func (store *MemStore) Commit(con *postgresql.Conn, q *query.Commit) (message.Responses, error)

+ func (store *MemStore) ParserError(conn *postgresql.Conn, q string, err error) (message.Responses, error)

+ func (store *MemStore) Rollback(*postgresql.Conn, *query.Rollback) (message.Responses, error)

Aug 18, 2023

Changes in this version

type MemStore

+ func (store *MemStore) Copy(conn *postgresql.Conn, q *query.Copy, stream *postgresql.CopyStream) (message.Responses, error)

Jul 27, 2023

Changes in this version

+ type Database struct

+ func NewDatabase() *Database

+ func NewDatabaseWithName(name string) *Database

+ func (db *Database) AddTable(table *Table) error

+ func (db *Database) AddTables(tables []*Table)

+ func (db *Database) DropTable(table *Table) error

+ func (db *Database) GetTable(name string) (*Table, bool)

+ func (db *Database) Name() string

+ func (db *Database) Tables() []*Table

+ type Databases map[string]*Database

+ func NewDatabases() Databases

+ func (dbs *Databases) GetTableWithDatabase(dbName string, tableName string) (*Table, bool)

+ func (dbs Databases) AddDatabase(db *Database) error

+ func (dbs Databases) DropDatabase(db *Database) error

+ func (dbs Databases) GetDatabase(name string) (*Database, bool)

+ type MemStore struct

+ func NewMemStore() *MemStore

+ func (store *MemStore) CreateDatabase(conn *postgresql.Conn, q *query.CreateDatabase) (message.Responses, error)

+ func (store *MemStore) CreateIndex(conn *postgresql.Conn, q *query.CreateIndex) (message.Responses, error)

+ func (store *MemStore) CreateTable(conn *postgresql.Conn, q *query.CreateTable) (message.Responses, error)

+ func (store *MemStore) Delete(conn *postgresql.Conn, q *query.Delete) (message.Responses, error)

+ func (store *MemStore) DropDatabase(conn *postgresql.Conn, q *query.DropDatabase) (message.Responses, error)

+ func (store *MemStore) DropTable(conn *postgresql.Conn, q *query.DropTable) (message.Responses, error)

+ func (store *MemStore) GetDatabaseTable(conn *postgresql.Conn, dbName string, tblName string) (*Database, *Table, error)

+ func (store *MemStore) Insert(conn *postgresql.Conn, q *query.Insert) (message.Responses, error)

+ func (store *MemStore) Select(conn *postgresql.Conn, q *query.Select) (message.Responses, error)

+ func (store *MemStore) Update(conn *postgresql.Conn, q *query.Update) (message.Responses, error)

+ type Row map[string]any

+ func NewRow() Row

+ func NewRowWith(cols []*query.Column) Row

+ func (row Row) IsEqual(other Row) bool

+ func (row Row) IsMatched(cond *query.Condition) bool

+ func (row Row) Update(colums []*query.Column)

+ func (row Row) ValueByName(name string) (any, error)

+ type Table struct

+ Name string

+ Rows []Row

+ func NewTableWith(name string, schema *query.Schema) *Table

+ func (tbl *Table) Delete(cond *query.Condition) (int, error)

+ func (tbl *Table) Insert(cols []*query.Column) error

+ func (tbl *Table) Select(cond *query.Condition) ([]Row, error)

+ func (tbl *Table) String() string

+ func (tbl *Table) Update(cols []*query.Column, cond *query.Condition) (int, error)