Documentation ¶
Overview ¶
package chai implements an embedded SQL database.
Example ¶
package main import ( "fmt" "github.com/chaisql/chai" ) type User struct { ID int64 Name string Age uint32 Address struct { City string ZipCode string } } func main() { // Create a database instance, here we'll store everything in memory db, err := chai.Open(":memory:") if err != nil { panic(err) } defer db.Close() // Create a table. Chai tables are schemaless by default, you don't need to specify a schema. err = db.Exec("CREATE TABLE user (name text, ...)") if err != nil { panic(err) } // Create an index. err = db.Exec("CREATE INDEX idx_user_name ON user (name)") if err != nil { panic(err) } // Insert some data err = db.Exec("INSERT INTO user (id, name, age) VALUES (?, ?, ?)", 10, "foo", 15) if err != nil { panic(err) } // Insert some data using object notation err = db.Exec(`INSERT INTO user VALUES {id: 12, "name": "bar", age: ?, address: {city: "Lyon", zipcode: "69001"}}`, 16) if err != nil { panic(err) } // Structs can be used to describe a object err = db.Exec("INSERT INTO user VALUES ?, ?", &User{ID: 1, Name: "baz", Age: 100}, &User{ID: 2, Name: "bat"}) if err != nil { panic(err) } // Query some objects stream, err := db.Query("SELECT * FROM user WHERE id > ?", 1) if err != nil { panic(err) } // always close the result when you're done with it defer stream.Close() // Iterate over the results err = stream.Iterate(func(r *chai.Row) error { var u User err = r.StructScan(&u) if err != nil { return err } fmt.Println(u) return nil }) if err != nil { panic(err) } }
Output: {10 foo 15 { }} {12 bar 16 {Lyon 69001}} {2 bat 0 { }}
Index ¶
- Variables
- func IsAlreadyExistsError(err error) bool
- type DB
- func (db *DB) Begin(writable bool) (*Tx, error)
- func (db *DB) Close() error
- func (db *DB) Exec(q string, args ...any) error
- func (db *DB) Prepare(q string) (*Statement, error)
- func (db *DB) Query(q string, args ...any) (*Result, error)
- func (db *DB) QueryRow(q string, args ...any) (*Row, error)
- func (db *DB) Update(fn func(tx *Tx) error) error
- func (db *DB) View(fn func(tx *Tx) error) error
- func (db DB) WithContext(ctx context.Context) *DB
- type Result
- type Row
- func (r *Row) Clone() *Row
- func (r *Row) Columns() ([]string, error)
- func (r *Row) GetColumnType(column string) (string, error)
- func (r *Row) Iterate(fn func(column string, value types.Value) error) error
- func (r *Row) MapScan(dest map[string]any) error
- func (r *Row) MarshalJSON() ([]byte, error)
- func (r *Row) Object() types.Object
- func (r *Row) Scan(dest ...any) error
- func (r *Row) ScanColumn(column string, dest any) error
- func (r *Row) StructScan(dest any) error
- type Statement
- type Tx
Examples ¶
Constants ¶
This section is empty.
Variables ¶
var IsNotFoundError = errs.IsNotFoundError
IsNotFoundError determines if the given error is a NotFoundError. NotFoundError is returned when the requested table, index, object or sequence doesn't exist.
Functions ¶
func IsAlreadyExistsError ¶
IsAlreadyExistsError determines if the error is returned as a result of a conflict when attempting to create a table, an index, an row or a sequence with a name that is already used by another resource.
Types ¶
type DB ¶
DB represents a collection of tables.
func Open ¶
Open creates a Chai database at the given path. If path is equal to ":memory:" it will open an in-memory database, otherwise it will create an on-disk database.
func (*DB) Begin ¶
Begin starts a new transaction. The returned transaction must be closed either by calling Rollback or Commit.
func (*DB) Query ¶
Query the database and return the result. The returned result must always be closed after usage.
type Result ¶
type Result struct {
// contains filtered or unexported fields
}
Result of a query.
func (*Result) MarshalJSON ¶
type Row ¶
type Row struct {
// contains filtered or unexported fields
}
func (*Row) MarshalJSON ¶
func (*Row) StructScan ¶
type Statement ¶
type Statement struct {
// contains filtered or unexported fields
}
Statement is a prepared statement. If Statement has been created on a Tx, it will only be valid until Tx closes. If it has been created on a DB, it is valid until the DB closes. It's safe for concurrent use by multiple goroutines.
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
Tx represents a database transaction. It provides methods for managing the collection of tables and the transaction itself. Tx is either read-only or read/write. Read-only can be used to read tables and read/write can be used to read, create, delete and modify tables.
Example ¶
db, err := chai.Open(":memory:") if err != nil { log.Fatal(err) } defer db.Close() tx, err := db.Begin(true) if err != nil { panic(err) } defer tx.Rollback() err = tx.Exec("CREATE TABLE IF NOT EXISTS user") if err != nil { log.Fatal(err) } err = tx.Exec("INSERT INTO user (id, name, age) VALUES (?, ?, ?)", 10, "foo", 15) if err != nil { log.Fatal(err) } r, err := tx.QueryRow("SELECT id, name, age FROM user WHERE name = ?", "foo") if err != nil { panic(err) } var u User err = r.StructScan(&u) if err != nil { panic(err) } fmt.Println(u) var id uint64 var name string var age uint8 err = r.Scan(&id, &name, &age) if err != nil { panic(err) } fmt.Println(id, name, age) err = tx.Commit() if err != nil { panic(err) }
Output: {10 foo 15 { }} 10 foo 15
func (*Tx) Commit ¶
Commit the transaction. Calling this method on read-only transactions will return an error.
func (*Tx) Query ¶
Query the database withing the transaction and returns the result. Closing the returned result after usage is not mandatory.
Directories ¶
Path | Synopsis |
---|---|
cmd
|
|
chai
Module
|
|
internal
|
|
database
Package database provides database primitives such as tables, transactions and indexes.
|
Package database provides database primitives such as tables, transactions and indexes. |
expr/glob
Package glob implements wildcard pattern matching algorithms for strings.
|
Package glob implements wildcard pattern matching algorithms for strings. |
object
Package object defines types to manipulate and compare objects and values.
|
Package object defines types to manipulate and compare objects and values. |