connection

package

Go to main page

Versions in this module

v0

v0.3.0

Jul 7, 2026

Changes in this version

+ const DefaultMaxRowsPerFetch

+ const DefaultQueryTimeout

type Connection

+ func (c *Connection) SetMaxRowsPerFetch(rows int)

+ func (c *Connection) SetQueryTimeout(timeout int)

type MessageType

+ const AUTOCOMMIT_OFF

+ const AUTOCOMMIT_ON

+ const CLOSE_STREAM

+ const DIRECT_STORED_PROCEDURE

+ const GET_STREAM_SIZE

+ const ISOLATION_LEVEL

+ const OPEN_STREAM

+ const PREPARE_STORED_PROCEDURE

+ const READ_COMMITTED

+ const READ_STREAM

+ const READ_STREAM_ODBC

+ const READ_UNCOMMITTED

+ const RETRIEVE_STREAM

+ const STORED_PROCEDURE_FETCH_DATA

+ const STORED_PROCEDURE_QUERY_EXECUTE

+ const STORED_PROCEDURE_UPDATE_EXECUTE

+ const STORE_BINARY_STREAM

+ const STORE_CHARACTER_STREAM

+ const STREAM_GET_BYTES

+ const STREAM_GET_POSITION

+ const STREAM_SET_BYTES

+ const STREAM_TRUNCATE

+ const TOGGLE_SYNCHRONOUS_COMMIT

type Rows

+ func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

+ func (r *Rows) ColumnTypeLength(index int) (length int64, ok bool)

+ func (r *Rows) ColumnTypeNullable(index int) (nullable, ok bool)

+ func (r *Rows) ColumnTypePrecisionScale(index int) (precision, scale int64, ok bool)

+ func (r *Rows) ColumnTypeScanType(index int) reflect.Type

v0.2.1

Oct 4, 2025

Changes in this version

type Connection

+ func (c *Connection) BeginTx(opts driver.TxOptions) (driver.Tx, error)

v0.2.0

Sep 27, 2025

Changes in this version

+ const VERSION_PROTOCOL

+ var ErrCouldNotDetectUsername = errors.New(...)

+ func FormatQuery(sqlText string, args ...interface{}) (string, int, []interface{})

+ type AnyType struct

+ func (v *AnyType) Int() int

+ type Column struct

+ func (c Column) Name() string

+ type Connection struct

+ TX bool

+ func Connect(addr string, namespace, login, password string) (connection Connection, err error)

+ func (c *Connection) ClassMethod(class, method string, result interface{}, args ...interface{}) (err error)

+ func (c *Connection) ClassMethodVoid(class, method string, args ...interface{}) (err error)

+ func (c *Connection) Commit() (err error)

+ func (c *Connection) DirectQuery(sqlText string, args ...interface{}) (*ResultSet, error)

+ func (c *Connection) DirectUpdate(sqlText string, args ...interface{}) (*Result, error)

+ func (c *Connection) Disconnect()

+ func (c *Connection) Exec(sqlText string, args ...interface{}) (res *Result, err error)

+ func (c *Connection) GlobalGet(global string, result interface{}, subs ...interface{}) (err error)

+ func (c *Connection) GlobalIsDefined(global string, subs ...interface{}) (bool, bool)

+ func (c *Connection) GlobalKill(global string, subs ...interface{}) (err error)

+ func (c *Connection) GlobalNext(global string, ind *string, subs ...interface{}) (hasNext bool, err error)

+ func (c *Connection) GlobalPrev(global string, ind *string, subs ...interface{}) (hasNext bool, err error)

+ func (c *Connection) GlobalSet(global string, value interface{}, subs ...interface{}) (err error)

+ func (c *Connection) IsOptionFastInsert() bool

+ func (c *Connection) IsOptionFastSelect() bool

+ func (c *Connection) Method(obj iris.Oref, method string, result interface{}, args ...interface{}) (err error)

+ func (c *Connection) MethodVoid(obj, method string, args ...interface{}) (err error)

+ func (c *Connection) Prepare(query string) (*Stmt, error)

+ func (c *Connection) PropertyGet(obj iris.Oref, property string, result interface{}) (err error)

+ func (c *Connection) Query(sqlText string, args ...interface{}) (rs *ResultSet, err error)

+ func (c *Connection) Rollback() (err error)

+ func (c *Connection) ServerVersion() (result string, err error)

+ type FeatureOption uint

+ const OptionDurableTransactions

+ const OptionFastInsert

+ const OptionFastSelect

+ const OptionFastSelectAndInsert

+ const OptionNone

+ const OptionNotNullable

+ const OptionRedirectOutput

+ type Message struct

+ func NewMessage(messageType MessageType) Message

+ func ReadMessage(conn *net.TCPConn) (msg Message, err error)

+ func (m *Message) AddRaw(value interface{})

+ func (m *Message) Dump(count uint32) []byte

+ func (m *Message) Get(value interface{}) error

+ func (m *Message) GetAny() AnyType

+ func (m *Message) GetRaw(value interface{}) error

+ func (m *Message) GetStatus() uint16

+ func (m *Message) Set(value interface{}) error

+ func (m *Message) SetSQLText(sqlText string) error

+ type MessageHeader struct

+ func NewMessageHeader(messageType MessageType) MessageHeader

+ func (mh *MessageHeader) GetStatus() uint16

+ func (mh *MessageHeader) SetCount(cnt uint32)

+ func (mh *MessageHeader) SetLength(length uint32)

+ func (mh *MessageHeader) SetStatementId(statementId uint32)

+ func (mh MessageHeader) GetLength() uint32

+ type MessageType string

+ const CLASSMETHOD_VALUE

+ const CLASSMETHOD_VOID

+ const COMMIT

+ const CONNECT

+ const DIRECT_QUERY

+ const DIRECT_UPDATE

+ const DISCONNECT

+ const FETCH_DATA

+ const GET_AUTO_GENERATED_KEYS

+ const GET_MORE_RESULTS

+ const GET_SERVER_ERROR

+ const GLOBAL_DATA

+ const GLOBAL_GET

+ const GLOBAL_KILL

+ const GLOBAL_ORDER

+ const GLOBAL_SET

+ const HANDSHAKE

+ const METHOD_VALUE

+ const METHOD_VOID

+ const MULTIPLE_RESULT_SETS_FETCH_DATA

+ const PREPARE

+ const PREPARED_QUERY

+ const PREPARED_UPDATE

+ const PROPERTY_GET

+ const PROPERTY_SET

+ const ROLLBACK

+ type Result struct

+ func (r Result) LastInsertId() (lastId int64, err error)

+ func (r Result) RowsAffected() (int64, error)

+ type ResultSet struct

+ func (rs *ResultSet) Next() ([]Value, error)

+ func (rs ResultSet) Columns() []Column

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) Columns() []string

+ func (r *Rows) Next(dest []driver.Value) (err error)

+ type SQLError struct

+ Message string

+ SQLCode int16

+ func (e *SQLError) Error() string

+ type SQLTYPE int16

+ const BIGINT

+ const BINARY

+ const BIT

+ const CHAR

+ const DATE

+ const DATE_HOROLOG

+ const DECIMAL

+ const DOUBLE

+ const FLOAT

+ const GUID

+ const INTEGER

+ const LONGVARBINARY

+ const LONGVARCHAR

+ const NUMERIC

+ const REAL

+ const SMALLINT

+ const TIME

+ const TIMESTAMP

+ const TIMESTAMP_POSIX

+ const TIME_HOROLOG

+ const TINYINT

+ const TYPE_DATE

+ const TYPE_TIME

+ const TYPE_TIMESTAMP

+ const VARBINARY

+ const VARCHAR

+ const WCHAR

+ const WLONGVARCHAR

+ const WVARCHAR

+ type StatementFeature struct

+ type Stmt struct

+ func (st *Stmt) Close() (err error)

+ func (st *Stmt) Exec(args []driver.Value) (res driver.Result, err error)

+ func (st *Stmt) NumInput() int

+ func (st *Stmt) Query(args []driver.Value) (rows driver.Rows, err error)

+ type Value interface

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