Versions in this module Expand all Collapse all v0 v0.0.4 Apr 23, 2024 Changes in this version + const INT_CHUNK_SIZE + type CloudBlob struct + func (blob *CloudBlob) GetBlob_File(filename string) error + func (blob *CloudBlob) GetBytes() ([]byte, error) + type CloudClob struct + func (clob *CloudClob) GetClob_File(filename string) error + func (clob *CloudClob) GetString() ([]byte, error) v0.0.2 Dec 8, 2023 Changes in this version + const ARRAY + const AUTO_TABLET_APPEND + const BIGINT + const BINARY + const BIT + const BLOB + const BLOB_FREE + const BLOB_GET_BINARY_STREAM + const BLOB_GET_BYTES + const BLOB_LENGTH + const BLOB_POSITION_BLOB_PATTERN + const BLOB_POSITION_BYTEARRAY_PATTERN + const BLOB_SET_BINARY_STREAM + const BLOB_SET_BYTES + const BLOB_TRUNCATE + const BOOLEAN + const B_REQ_AUTO_TABLET_INSERT_FILES + const B_REQ_AUTO_TABLET_SYNC + const B_REQ_BFILE_BATCH_CREATE + const B_REQ_BFILE_BATCH_WRITE + const B_REQ_BFILE_CLOSE + const B_REQ_BFILE_CREATE + const B_REQ_BFILE_DELETE + const B_REQ_BFILE_GETALL + const B_REQ_BFILE_GETBYNAME + const B_REQ_BFILE_GET_BY_ID + const B_REQ_BFILE_GET_NFSBFILE_INPUTSTREAM + const B_REQ_BFILE_GET_SEGMENT_TABLET_SERVER + const B_REQ_BFILE_NFSBFILE_CREATE + const B_REQ_BFILE_READ + const B_REQ_BFILE_SYNC + const B_REQ_BFILE_WRITE + const B_REQ_BUILD_CONNECTION + const B_REQ_CLOSE_CONNECTION + const B_REQ_GET_NEXT_TABLET_SERVER + const B_REQ_PING + const B_REQ_STOP_SERVER + const B_REQ_TABLET_SERVER_CONNECT + const B_REQ_TAG + const CHAR + const CHECK_POINT + const CLEAR_CACHE + const CLOB + const CLOB_FREE + const CLOB_GET_ASCII_STREAM + const CLOB_GET_CHARACTER_STREAM + const CLOB_GET_SUB_STRING + const CLOB_LENGTH + const CLOB_POSITION_CLOB + const CLOB_POSITION_STRING + const CLOB_READ + const CLOB_SET_ASCII_STREAM + const CLOB_SET_CHARACTER_STREAM + const CLOB_SET_STRING + const CLOB_TRUNCATE + const CLOB_WRITE + const CLOSE_DB_FILE_OUTPUT + const CLOSE_PREPARED_STATEMENT + const CLOSE_STATEMENT + const CLOUDWAVE_EXECUTE + const CLOUDWAVE_EXECUTE_QUERY + const CLOUDWAVE_EXECUTE_UPDATE + const CLOUDWAVE_SELFUSEDRIVE + const CLOUD_TYPE_ARRAY + const CLOUD_TYPE_BFILE + const CLOUD_TYPE_BIG_DECIMAL + const CLOUD_TYPE_BIG_INTEGER + const CLOUD_TYPE_BINARY + const CLOUD_TYPE_BLOB + const CLOUD_TYPE_BOOLEAN + const CLOUD_TYPE_BYTE + const CLOUD_TYPE_CHAR + const CLOUD_TYPE_CLOB + const CLOUD_TYPE_COLLECTOR_SELECTION + const CLOUD_TYPE_COMPACT_DATE + const CLOUD_TYPE_DATE + const CLOUD_TYPE_DAY_TIME_INTERVAL + const CLOUD_TYPE_DEFAULT + const CLOUD_TYPE_DOUBLE + const CLOUD_TYPE_DOUBLE_LONG + const CLOUD_TYPE_FISCAL_QUARTER + const CLOUD_TYPE_FISCAL_YEAR + const CLOUD_TYPE_FLOAT + const CLOUD_TYPE_GROUPING + const CLOUD_TYPE_INTEGER + const CLOUD_TYPE_INTERVAL + const CLOUD_TYPE_INTS + const CLOUD_TYPE_JAVA_STRING + const CLOUD_TYPE_JSON_ARRAY + const CLOUD_TYPE_JSON_BIGDECIMAL + const CLOUD_TYPE_JSON_BINARY + const CLOUD_TYPE_JSON_KEYWORD + const CLOUD_TYPE_JSON_OBJECT + const CLOUD_TYPE_JSON_TEXT + const CLOUD_TYPE_LONG + const CLOUD_TYPE_LONGVARBINARY + const CLOUD_TYPE_LONGVARCHAR + const CLOUD_TYPE_MEDIA + const CLOUD_TYPE_NOTHING + const CLOUD_TYPE_NULL + const CLOUD_TYPE_NUMBER + const CLOUD_TYPE_OTHER + const CLOUD_TYPE_PAIR + const CLOUD_TYPE_RANGE_STRING + const CLOUD_TYPE_RANK + const CLOUD_TYPE_REVERSE + const CLOUD_TYPE_ROWID + const CLOUD_TYPE_SHARED_COLUMN + const CLOUD_TYPE_SINGLE_BYTE + const CLOUD_TYPE_SINGLE_CHAR + const CLOUD_TYPE_SMALL_DECIMAL + const CLOUD_TYPE_SMALL_INTEGER + const CLOUD_TYPE_TIME + const CLOUD_TYPE_TIMESTAMP + const CLOUD_TYPE_TIME_INTERVAL + const CLOUD_TYPE_TINY_DECIMAL + const CLOUD_TYPE_TINY_INTEGER + const CLOUD_TYPE_VARBINARY + const CLOUD_TYPE_VARCHAR + const CLOUD_TYPE_X1_LONG + const CLOUD_TYPE_X2_LONG + const CLOUD_TYPE_X_BYTES + const CLOUD_TYPE_X_LONG + const CLOUD_TYPE_YEAR_MONTH + const CLOUD_TYPE_YEAR_MONTH_DAY + const CLOUD_TYPE_YEAR_MONTH_INTERVAL + const CLOUD_TYPE_ZONE_AUTO_SEQUENCE + const CONNECTION_CALLABLE_STATEMENT + const CONNECTION_CANCEL_STATEMENT + const CONNECTION_COMMIT + const CONNECTION_CREATE_BLOB + const CONNECTION_CREATE_BLOBS + const CONNECTION_CREATE_CLOB + const CONNECTION_CREATE_CLOBS + const CONNECTION_CREATE_STATEMENT + const CONNECTION_PREPARED_STATEMENT + const CONNECTION_ROLLBACK + const CONNECTION_SET_AUTO_COMMIT + const CONNECTION_SET_CHECK_CONSTRAINTS + const CONNECTION_SET_CLIENT_PROPERTIES + const CONNECTION_SET_ENABLE_SAME_COLUMN_LINK + const CONNECTION_SET_TABLET_SPLIT_THRESHOLD + const CONNECTION_SHUT_DOWN_SERVER + const CREATE_FULL_TEXT_INDEX + const CREATE_TABLET + const CREATE_UDF + const DATAAREALEN + const DATABASE_COLLECT_LOGGER + const DATABASE_GET_RUNTIME_REPORT + const DATABASE_GET_SQL_HISTORYS + const DATABASE_GET_SQL_STATISTICS + const DATABASE_HEALTH_DIAGNOSTIC + const DATABASE_META_DATA_GET_CATALOGS + const DATABASE_META_DATA_GET_COLUMNS + const DATABASE_META_DATA_GET_COLUMNS_DEFAULT + const DATABASE_META_DATA_GET_DB_FILES + const DATABASE_META_DATA_GET_DB_FILE_DATA + const DATABASE_META_DATA_GET_EXPORTED_KEYS + const DATABASE_META_DATA_GET_IMPORTED_KEYS + const DATABASE_META_DATA_GET_LINK_KEYS + const DATABASE_META_DATA_GET_MEMORY_SIZE + const DATABASE_META_DATA_GET_NETWORK_STATUS + const DATABASE_META_DATA_GET_PRIMARY_KEYS + const DATABASE_META_DATA_GET_RECORD_COUNT_OF_ALL_TABLETS + const DATABASE_META_DATA_GET_SCHEMAS + const DATABASE_META_DATA_GET_SCHEMA_FILES + const DATABASE_META_DATA_GET_SCHEMA_OWNER + const DATABASE_META_DATA_GET_SEQUENCES + const DATABASE_META_DATA_GET_SERVERS + const DATABASE_META_DATA_GET_SHARES + const DATABASE_META_DATA_GET_SYNONYM_COLUMNS + const DATABASE_META_DATA_GET_SYSTEM_UTILIZATION + const DATABASE_META_DATA_GET_TABLES + const DATABASE_META_DATA_GET_TABLESPACES + const DATABASE_META_DATA_GET_TABLETS + const DATABASE_META_DATA_GET_TABLET_COUNT + const DATABASE_META_DATA_GET_TABLE_BASESEARCH_COLUMNS + const DATABASE_META_DATA_GET_TABLE_PRIVILEGES + const DATABASE_META_DATA_GET_TABLE_SYNONYMS + const DATABASE_META_DATA_GET_TABLE_TYPES + const DATABASE_META_DATA_GET_TYPE_INFO + const DATABASE_META_DATA_GET_UNIQUE_KEYS + const DATABASE_META_DATA_GET_USERS + const DATABASE_META_DATA_GET_USER_PRIVILEGES + const DATABASE_META_DATA_GET_USER_TABLE_PRIVILEGES + const DATABASE_META_DATA_LIST_SCHEMAS + const DATABASE_META_DATA_LIST_TABLES + const DATABASE_RESTART_SERVER + const DATABASE_SET_SHARE_QUERYAREA + const DATABASE_UPDATE_LICENSE + const DATABASE_UPDATE_PATCH + const DATALINK + const DATA_LOAD + const DATE + const DECIMAL + const DELETE_FULL_TEXT_INDEX + const DELETE_UDF + const DISPLAY + const DISTINCT + const DOUBLE + const DataAvailableTime + const EXECUTE_BATCH + const EXECUTE_BATCH_PREPARED + const EXECUTE_CALLABLE_STATEMENT + const EXECUTE_GC + const EXECUTE_PREPARED_STATEMENT + const EXECUTE_STATEMENT + const EXECUTE_STATEMENT_4_MR + const EXECUTE_STATEMENT_BATCH_INSERT + const E_REQ_TAG + const FLOAT + const FULL_TEXT_SEARCH + const GET_ALL_DOWNLEVELS + const GET_BFILE_CONTENT_TABLE_EVERY_LENGTH + const GET_BFILE_CONTENT_TABLE_TOTAL_LENGTH + const GET_BFILE_TABLE_TOTAL_LENGTH + const GET_CACHE + const GET_CONFIG_OPTIONS + const GET_CPU_INFO + const GET_DOWNLEVEL_CHAINS + const GET_FULLTEXTINDEX_INFO + const GET_FULLTEXT_INDEX_IS_AND_OPERATOR + const GET_HDFS_DATA_BLOCK_SIZE + const GET_INC_LOGS + const GET_INDEX_INFO + const GET_INFO_FOR_MAP_REDUCE + const GET_INFO_FROM_HDFS + const GET_ONLINE_USER + const GET_RUNNING_SQL + const GET_RUNNING_TASK + const GET_SERVER_LOGGER + const GET_SERVER_VERSION + const GET_SYNONYM_HINTS + const GET_SYSTEM_OVERVIEW + const GET_TABLET_RESULT_SET + const GET_TEXTINDEX_INFO + const GET_THREAD_INFO + const GET_TRANSACTION_ISOLATION + const GET_UDF_CLASS_NAME + const GET_UDF_METHOD_NAMES + const GET_ZONE_SERVERS + const HIGHLIGHT + const INSERT_DB_FILE_DATA + const INTEGER + const INT_MAX_VALUE + const INT_MIN_VALUE + const IS_BFILE_UFS_STORE + const JAVA_OBJECT + const LOB_GET_DATA_BLOCK_INFO + const LOB_READ_BUFFER + const LOB_WRITE_BUFFER + const LONGNVARCHAR + const LONGVARBINARY + const LONGVARCHAR + const LONG_MAX_VALUE + const LONG_MIN_VALUE + const NCHAR + const NCLOB + const NULL + const NUMERIC + const NVARCHAR + const OTHER + const REAL + const REDO_INC_LOGS + const REF + const REFRESH + const REF_CURSOR + const RELOAD_CONFIGURATION + const RESULT_SET_CLOSE + const RESULT_SET_GET_DISTRIBUTION + const RESULT_SET_GET_EXECUTION_INFO + const RESULT_SET_GET_EXECUTION_STATISTICS + const RESULT_SET_GET_RECORD_COUNT + const RESULT_SET_GET_TABLET_IDS + const RESULT_SET_GET_TABLET_PARTITION_IDS + const RESULT_SET_QUERY_NEXT + const RESULT_SET_QUERY_PREV + const RESULT_SET_RESOVE_LARGE_STRING_REF + const ROWID + const SET_AUTO_TABLET_RECORDCOUNT + const SET_FULLTEXT_INDEX_IS_AND_OPERATOR + const SET_SCHEMA + const SET_TRANSACTION_ISOLATION + const SMALLINT + const SQLXML + const STRUCT + const TABLE_GET_RECORDS_BY_PKS + const TIME + const TIMESTAMP + const TIMESTAMP_WITH_TIMEZONE + const TIME_WITH_TIMEZONE + const TINYINT + const UPDATE_CONFIG_OPTIONS + const VARBINARY + const VARCHAR + var ErrBusyBuffer = errors.New("busy buffer") + var ErrCleartextPassword = errors.New(...) + var ErrInvalidConn = errors.New("invalid connection") + var ErrMalformPkt = errors.New("malformed packet") + var ErrNativePassword = errors.New("this user requires cloudwave native password authentication.") + var ErrNoTLS = errors.New("TLS requested but server does not support TLS") + var ErrOldPassword = errors.New(...) + var ErrOldProtocol = errors.New("CloudWave server does not support required protocol 41+") + var ErrPktSync = errors.New("commands out of sync. You can't run this command now") + var ErrPktSyncMul = errors.New("commands out of sync. Did you run multiple statements at once?") + var ErrPktTooLarge = errors.New(...) + var ErrUnknownPlugin = errors.New("this authentication plugin is not supported") + func DeregisterLocalFile(filePath string) + func DeregisterReaderHandler(name string) + func DeregisterServerPubKey(name string) + func DeregisterTLSConfig(key string) + func NewConnector(cfg *Config) (driver.Connector, error) + func PullData(i int) []byte + func ReadLengthEncodedString(b []byte) ([]byte, bool, int, error) + func RegisterDial(network string, dial DialFunc) + func RegisterDialContext(net string, dial DialContextFunc) + func RegisterLocalFile(filePath string) + func RegisterReaderHandler(name string, handler func() io.Reader) + func RegisterServerPubKey(name string, pubKey *rsa.PublicKey) + func RegisterTLSConfig(key string, config *tls.Config) error + func SetLogger(logger Logger) error + func Ucs2ToUtf8(ucs2 []byte, count int) ([]byte, int, error) + func Utf8ToUcs2(utf8 []byte, utf8len int) ([]byte, int, error) + type CloudWaveDriver struct + func (d CloudWaveDriver) Open(dsn string) (driver.Conn, error) + func (d CloudWaveDriver) OpenConnector(dsn string) (driver.Connector, error) + type CloudWaveError struct + Message string + func (me *CloudWaveError) Error() string + func (me *CloudWaveError) Is(err error) bool + type Config struct + Addr string + AllowAllFiles bool + AllowCleartextPasswords bool + AllowNativePasswords bool + AllowOldPasswords bool + CheckConnLiveness bool + ClientFoundRows bool + Collation string + ColumnsWithAlias bool + DBName string + InterpolateParams bool + Loc *time.Location + MaxAllowedPacket int + MultiStatements bool + Net string + Params map[string]string + ParseTime bool + Passwd string + ReadTimeout time.Duration + RejectReadOnly bool + ServerPubKey string + TLSConfig string + Timeout time.Duration + User string + WriteTimeout time.Duration + func NewConfig() *Config + func ParseDSN(dsn string) (cfg *Config, err error) + func (cfg *Config) Clone() *Config + func (cfg *Config) FormatDSN() string + type DialContextFunc func(ctx context.Context, addr string) (net.Conn, error) + type DialFunc func(addr string) (net.Conn, error) + type Logger interface + Print func(v ...interface{}) + type NullTime sql.NullTime + func (nt *NullTime) Scan(value interface{}) (err error) + func (nt NullTime) Value() (driver.Value, error)