Versions in this module Expand all Collapse all v0 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