db

Documentation

Index

• func ColumnValue(a arrow.Array, i int) any
• func RecordToJSON(rec arrow.Record, asArray bool, w io.Writer) error
• type Arrow
  • func (a *Arrow) Close() error
• type ArrowTable
  • func NewDBJsonTable(releaseAfterMarshal bool) *ArrowTable
  • func (t *ArrowTable) Append(rec arrow.Record)
  • func (t *ArrowTable) Chunk(i int) arrow.Record
  • func (t *ArrowTable) DecodeMsgpack(dec *msgpack.Decoder) error
  • func (t *ArrowTable) EncodeMsgpack(enc *msgpack.Encoder) error
  • func (t *ArrowTable) MarshalJSON() ([]byte, error)
  • func (t *ArrowTable) NumChunks() int
  • func (t *ArrowTable) NumCols() int
  • func (t *ArrowTable) NumRows() int
  • func (t *ArrowTable) Release()
  • func (t *ArrowTable) RowData(i int) (map[string]any, bool)
  • func (t *ArrowTable) SetAutoRelease(release bool)
• type Config
• type Connection
  • func (c *Connection) Close() error
  • func (c *Connection) DBConn() *sql.Conn
  • func (c *Connection) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (c *Connection) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (c *Connection) QueryRow(ctx context.Context, query string, args ...any) *sql.Row
• type JsonValue
  • func (v *JsonValue) MarshalJSON() ([]byte, error)
• type Pool
  • func Connect(ctx context.Context, config Config) (*Pool, error)
  • func NewPool(path string) (*Pool, error)
  • func (p *Pool) Arrow(ctx context.Context) (*Arrow, error)
  • func (p *Pool) Close() error
  • func (p *Pool) Commit(ctx context.Context) error
  • func (p *Pool) Conn(ctx context.Context) (*Connection, error)
  • func (p *Pool) Connector() *duckdb.Connector
  • func (p *Pool) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (p *Pool) IsTxContext(ctx context.Context) bool
  • func (db *Pool) QueryArrowTable(ctx context.Context, q string, wrap bool, params ...any) (any, error)
  • func (db *Pool) QueryJsonRow(ctx context.Context, q string, params ...any) (*JsonValue, error)
  • func (db *Pool) QueryJsonScalarArray(ctx context.Context, q string, params ...any) (any, error)
  • func (db *Pool) QueryJsonScalarArrayArrow(ctx context.Context, q string, params ...any) (*ArrowTable, error)
  • func (db *Pool) QueryJsonTableArrow(ctx context.Context, q string, wrap bool, params ...any) (*ArrowTable, error)
  • func (db *Pool) QueryRowToData(ctx context.Context, data any, q string, params ...any) error
  • func (db *Pool) QueryTableToSlice(ctx context.Context, data any, q string, params ...any) error
  • func (p *Pool) Rollback(ctx context.Context) error
  • func (p *Pool) SetMaxIdleConns(n int)
  • func (p *Pool) SetMaxOpenConns(n int)
  • func (p *Pool) WithTx(parent context.Context) (context.Context, error)
• type Settings

Functions

func ColumnValue

func ColumnValue(a arrow.Array, i int) any

func RecordToJSON

func RecordToJSON(rec arrow.Record, asArray bool, w io.Writer) error

Types

type Arrow

type Arrow struct {
	*duckdb.Arrow
	// contains filtered or unexported fields
}

func (*Arrow) Close

func (a *Arrow) Close() error

type ArrowTable

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

func NewDBJsonTable

func NewDBJsonTable(releaseAfterMarshal bool) *ArrowTable

func (*ArrowTable) Append

func (t *ArrowTable) Append(rec arrow.Record)

func (*ArrowTable) Chunk

func (t *ArrowTable) Chunk(i int) arrow.Record

func (*ArrowTable) DecodeMsgpack

func (t *ArrowTable) DecodeMsgpack(dec *msgpack.Decoder) error

func (*ArrowTable) EncodeMsgpack

func (t *ArrowTable) EncodeMsgpack(enc *msgpack.Encoder) error

func (*ArrowTable) MarshalJSON

func (t *ArrowTable) MarshalJSON() ([]byte, error)

func (*ArrowTable) NumChunks

func (t *ArrowTable) NumChunks() int

func (*ArrowTable) NumCols

func (t *ArrowTable) NumCols() int

func (*ArrowTable) NumRows

func (t *ArrowTable) NumRows() int

func (*ArrowTable) Release

func (t *ArrowTable) Release()

func (*ArrowTable) RowData

func (t *ArrowTable) RowData(i int) (map[string]any, bool)

func (*ArrowTable) SetAutoRelease

func (t *ArrowTable) SetAutoRelease(release bool)

type Config

type Config struct {
	Path         string
	MaxOpenConns int
	MaxIdleConns int

	Settings Settings
}

type Connection

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

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) DBConn

func (c *Connection) DBConn() *sql.Conn

func (*Connection) Exec

func (c *Connection) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

func (*Connection) Query

func (c *Connection) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*Connection) QueryRow

func (c *Connection) QueryRow(ctx context.Context, query string, args ...any) *sql.Row

type JsonValue

type JsonValue string

func (*JsonValue) MarshalJSON

func (v *JsonValue) MarshalJSON() ([]byte, error)

type Pool

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

func Connect

func Connect(ctx context.Context, config Config) (*Pool, error)

func NewPool

func NewPool(path string) (*Pool, error)

func (*Pool) Arrow

func (p *Pool) Arrow(ctx context.Context) (*Arrow, error)

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) Commit

func (p *Pool) Commit(ctx context.Context) error

func (*Pool) Conn

func (p *Pool) Conn(ctx context.Context) (*Connection, error)

func (*Pool) Connector

func (p *Pool) Connector() *duckdb.Connector

func (*Pool) Exec

func (p *Pool) Exec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*Pool) IsTxContext

func (p *Pool) IsTxContext(ctx context.Context) bool

func (*Pool) QueryArrowTable

func (db *Pool) QueryArrowTable(ctx context.Context, q string, wrap bool, params ...any) (any, error)

func (*Pool) QueryJsonRow

func (db *Pool) QueryJsonRow(ctx context.Context, q string, params ...any) (*JsonValue, error)

func (*Pool) QueryJsonScalarArray

func (db *Pool) QueryJsonScalarArray(ctx context.Context, q string, params ...any) (any, error)

func (*Pool) QueryJsonScalarArrayArrow

func (db *Pool) QueryJsonScalarArrayArrow(ctx context.Context, q string, params ...any) (*ArrowTable, error)

func (*Pool) QueryJsonTableArrow

func (db *Pool) QueryJsonTableArrow(ctx context.Context, q string, wrap bool, params ...any) (*ArrowTable, error)

func (*Pool) QueryRowToData

func (db *Pool) QueryRowToData(ctx context.Context, data any, q string, params ...any) error

func (*Pool) QueryTableToSlice

func (db *Pool) QueryTableToSlice(ctx context.Context, data any, q string, params ...any) error

func (*Pool) Rollback

func (p *Pool) Rollback(ctx context.Context) error

func (*Pool) SetMaxIdleConns

func (p *Pool) SetMaxIdleConns(n int)

func (*Pool) SetMaxOpenConns

func (p *Pool) SetMaxOpenConns(n int)

func (*Pool) WithTx

func (p *Pool) WithTx(parent context.Context) (context.Context, error)

type Settings

type Settings struct {
	AllowedDirectories   []string
	AllowedPaths         []string
	EnableLogging        bool
	MaxMemory            int
	MaxTempDirectorySize int
	TempDirectory        string
	WorkerThreads        int
	// POSTGRESQL
	PGConnectionLimit int
	PGPagesPerTask    int
}