Versions in this module Expand all Collapse all v1 v1.0.0 Oct 23, 2023 Changes in this version + type Batch struct + Steps []BatchStep + func (b *Batch) Add(stmt Stmt) + type BatchCondition struct + Cond *BatchCondition + Conds []BatchCondition + Step *int32 + Type string + type BatchResult struct + StepErrors []*Error + StepResults []*StmtResult + type BatchStep struct + Condition *BatchCondition + Stmt Stmt + type Column struct + Name *string + Type *string + type Error struct + Code *string + Message string + type NamedArg struct + Name string + Value Value + type PipelineRequest struct + Baton string + Requests []StreamRequest + func (pr *PipelineRequest) Add(request StreamRequest) + type PipelineResponse struct + BaseUrl string + Baton string + Results []StreamResult + type Stmt struct + Args []Value + NamedArgs []NamedArg + Sql *string + SqlId *int32 + WantRows bool + func (s *Stmt) AddArgs(params shared.Params) error + func (s *Stmt) AddNamedArgs(args map[string]any) error + func (s *Stmt) AddPositionalArgs(args []any) error + type StmtResult struct + AffectedRowCount int32 + Cols []Column + LastInsertRowId *string + Rows [][]Value + func (r *StmtResult) GetLastInsertRowId() int64 + type StreamRequest struct + Batch *Batch + Sql *string + SqlId *int32 + Stmt *Stmt + Type string + func BatchStream(sqls []string, params []shared.Params, wantRows bool) (*StreamRequest, error) + func CloseStoredSqlStream(sqlId int32) StreamRequest + func CloseStream() StreamRequest + func ExecuteStoredStream(sqlId int32, params shared.Params, wantRows bool) (*StreamRequest, error) + func ExecuteStream(sql string, params shared.Params, wantRows bool) (*StreamRequest, error) + func StoreSqlStream(sql string, sqlId int32) StreamRequest + type StreamResponse struct + Result json.RawMessage + Type string + func (r *StreamResponse) BatchResult() (*BatchResult, error) + func (r *StreamResponse) ExecuteResult() (*StmtResult, error) + type StreamResult struct + Error *Error + Response *StreamResponse + Type string + type Value struct + Base64 string + Type string + Value any + func ToValue(v any) (Value, error) + func (v Value) ToValue(columnType *string) any
Go to main page