Versions in this module Expand all Collapse all v0 v0.1.0 Aug 26, 2026 Changes in this version + const ColumnNoNulls + const ColumnNullable + const ColumnNullableUnknown + const JDBCArray + const JDBCBigInt + const JDBCBinary + const JDBCBit + const JDBCBoolean + const JDBCChar + const JDBCDate + const JDBCDecimal + const JDBCDouble + const JDBCFloat + const JDBCInteger + const JDBCJavaObject + const JDBCLongVarBinary + const JDBCLongVarchar + const JDBCNull + const JDBCNumeric + const JDBCOther + const JDBCReal + const JDBCSmallInt + const JDBCStruct + const JDBCTime + const JDBCTimestamp + const JDBCTinyInt + const JDBCVarBinary + const JDBCVarchar + func AtBeginning(c Continuation) bool + func AtEnd(c Continuation) bool + func DefaultOptionValues() map[OptionName]any + func IsTransactionTimeLimit(err error) bool + func JDBCFromSQLTypeName(name SQLTypeName) int + func JDBCType(c Code) int + func VisitSchemaTemplateTree(s SchemaTemplate, v Visitor) + func VisitTableTree(t Table, v Visitor) + type Array interface + BaseType func() int + BaseTypeName func() string + Element func(oneBasedIndex int) (any, error) + Elements func() []any + Length func() int + MetaData func() ArrayMetaData + type ArrayMetaData interface + ElementDataType func() DataType + ElementType func() int + ElementTypeName func() string + Nullable func() int + type ArrayType struct + func NewArrayType(elementType DataType, isNullable bool) *ArrayType + func (b ArrayType) Code() Code + func (b ArrayType) IsNullable() bool + func (b ArrayType) IsPrimitive() bool + func (t *ArrayType) ElementType() DataType + func (t *ArrayType) Equal(other DataType) bool + func (t *ArrayType) HasIdenticalStructure(other any) bool + func (t *ArrayType) IsResolved() bool + func (t *ArrayType) Resolve(resolution map[string]Named) DataType + func (t *ArrayType) String() string + func (t *ArrayType) WithNullable(isNullable bool) DataType + type BooleanType struct + func NewBooleanType(isNullable bool) *BooleanType + func (b BooleanType) Code() Code + func (b BooleanType) IsNullable() bool + func (b BooleanType) IsPrimitive() bool + func (t *BooleanType) Equal(other DataType) bool + func (t *BooleanType) IsResolved() bool + func (t *BooleanType) Resolve(_ map[string]Named) DataType + func (t *BooleanType) String() string + func (t *BooleanType) WithNullable(isNullable bool) DataType + type BytesType struct + func NewBytesType(isNullable bool) *BytesType + func (b BytesType) Code() Code + func (b BytesType) IsNullable() bool + func (b BytesType) IsPrimitive() bool + func (t *BytesType) Equal(other DataType) bool + func (t *BytesType) IsResolved() bool + func (t *BytesType) Resolve(_ map[string]Named) DataType + func (t *BytesType) String() string + func (t *BytesType) WithNullable(isNullable bool) DataType + type Code uint8 + const CodeArray + const CodeBoolean + const CodeBytes + const CodeDate + const CodeDouble + const CodeEnum + const CodeFloat + const CodeInteger + const CodeLong + const CodeNull + const CodeString + const CodeStruct + const CodeTimestamp + const CodeUUID + const CodeUnknown + const CodeVector + const CodeVersion + func (c Code) String() string + type Column interface + DataType func() DataType + type CompositeType interface + HasIdenticalStructure func(other any) bool + type Connection interface + AutoCommit func() bool + Close func() error + Commit func() error + CreateStatement func(ctx context.Context) (Statement, error) + IsClosed func() bool + Options func() *Options + Path func() *url.URL + PrepareStatement func(ctx context.Context, sql string) (PreparedStatement, error) + Rollback func() error + Schema func() string + SetAutoCommit func(autoCommit bool) error + SetOption func(name OptionName, value any) error + SetSchema func(schema string) error + type Continuation interface + ExecutionState func() []byte + Reason func() ContinuationReason + Serialize func() []byte + type ContinuationReason int + const ContinuationCursorAfterLast + const ContinuationQueryExecutionLimitReached + const ContinuationTransactionLimitReached + const ContinuationUserRequested + func (r ContinuationReason) String() string + type CrossDatabaseDDLError struct + Operation string + SessionDatabase string + TargetDatabase string + func (e *CrossDatabaseDDLError) Error() string + type DataType interface + Code func() Code + Equal func(other DataType) bool + IsNullable func() bool + IsPrimitive func() bool + IsResolved func() bool + Resolve func(resolution map[string]Named) DataType + String func() string + WithNullable func(isNullable bool) DataType + func DataTypeFromSQLTypeName(name SQLTypeName) DataType + type DatabaseMetaData interface + Columns func(ctx context.Context, ...) (ResultSet, error) + DatabaseProductName func() string + DatabaseProductVersion func() string + DriverName func() string + DriverVersion func() string + IndexInfo func(ctx context.Context, catalog, schema, table string, unique, approximate bool) (ResultSet, error) + IsReadOnly func() bool + PrimaryKeys func(ctx context.Context, catalog, schema, table string) (ResultSet, error) + Schemas func(ctx context.Context) (ResultSet, error) + SchemasFiltered func(ctx context.Context, catalog, schemaPattern string) (ResultSet, error) + Tables func(ctx context.Context, catalog, schemaPattern, tableNamePattern string, ...) (ResultSet, error) + URL func() string + UserName func() string + type DateType struct + func NewDateType(isNullable bool) *DateType + func (b DateType) Code() Code + func (b DateType) IsNullable() bool + func (b DateType) IsPrimitive() bool + func (t *DateType) Equal(other DataType) bool + func (t *DateType) IsResolved() bool + func (t *DateType) Resolve(_ map[string]Named) DataType + func (t *DateType) String() string + func (t *DateType) WithNullable(isNullable bool) DataType + type DirectAccessStatement interface + ExecuteDelete func(ctx context.Context, tableName string, key *KeySet, opts *Options) (int64, error) + ExecuteDeleteRange func(ctx context.Context, tableName string, keyPrefix *KeySet, opts *Options) (int64, error) + ExecuteGet func(ctx context.Context, tableName string, key *KeySet, opts *Options) (ResultSet, error) + ExecuteInsert func(ctx context.Context, tableName string, data []Struct, opts *Options) (int64, error) + ExecuteScan func(ctx context.Context, tableName string, keyPrefix *KeySet, opts *Options) (ResultSet, error) + type DoubleType struct + func NewDoubleType(isNullable bool) *DoubleType + func (b DoubleType) Code() Code + func (b DoubleType) IsNullable() bool + func (b DoubleType) IsPrimitive() bool + func (t *DoubleType) Equal(other DataType) bool + func (t *DoubleType) IsResolved() bool + func (t *DoubleType) Resolve(_ map[string]Named) DataType + func (t *DoubleType) String() string + func (t *DoubleType) WithNullable(isNullable bool) DataType + type Driver interface + Connect func(ctx context.Context, url *url.URL, opts *Options) (Connection, error) + MajorVersion func() int + MinorVersion func() int + type EnumType struct + func NewEnumType(name string, values []EnumValue, isNullable bool) *EnumType + func (b EnumType) Code() Code + func (b EnumType) IsNullable() bool + func (b EnumType) IsPrimitive() bool + func (t *EnumType) Equal(other DataType) bool + func (t *EnumType) IsResolved() bool + func (t *EnumType) Name() string + func (t *EnumType) Resolve(_ map[string]Named) DataType + func (t *EnumType) String() string + func (t *EnumType) Values() []EnumValue + func (t *EnumType) WithNullable(isNullable bool) DataType + type EnumValue struct + func NewEnumValue(name string, number int) EnumValue + func (v EnumValue) Name() string + func (v EnumValue) Number() int + func (v EnumValue) String() string + type Error struct + Cause error + Code ErrorCode + Context map[string]any + Message string + func AsError(err error) *Error + func MarkFDBTransactionTooOld(cause error) *Error + func NewCrossDatabaseDDLError(operation, sessionDatabase, targetDatabase string) *Error + func NewError(code ErrorCode, message string) *Error + func NewErrorf(code ErrorCode, format string, args ...any) *Error + func NewSchemaTemplateDDLRestrictedError(operation, sessionDatabase string) *Error + func NewTransactionTimeLimitError(elapsed, limit time.Duration) *Error + func WrapError(code ErrorCode, message string, cause error) *Error + func WrapErrorf(cause error, code ErrorCode, format string, args ...any) *Error + func (e *Error) Error() string + func (e *Error) Unwrap() error + func (e *Error) WithContext(key string, value any) *Error + type ErrorCode string + const ErrCodeAmbiguousColumn + const ErrCodeAnnotationAlreadyExists + const ErrCodeArrayElementError + const ErrCodeCannotCommitRollbackWithAutocommit + const ErrCodeCannotConvertType + const ErrCodeCardinalityViolation + const ErrCodeColumnAlreadyExists + const ErrCodeConnectionDoesNotExist + const ErrCodeCopyImportValidationError + const ErrCodeCopySerializationError + const ErrCodeDatabaseAlreadyExists + const ErrCodeDatatypeMismatch + const ErrCodeDeserializationFailure + const ErrCodeDivisionByZero + const ErrCodeDuplicateAlias + const ErrCodeDuplicateFunction + const ErrCodeDuplicateSchemaTemplate + const ErrCodeExecuteUpdateReturnedResultSet + const ErrCodeExecutionLimitReached + const ErrCodeGroupingError + const ErrCodeIncompatibleTableAlias + const ErrCodeIncorrectMetadataTableVersion + const ErrCodeIndexAlreadyExists + const ErrCodeInsufficientPrivilege + const ErrCodeInternalError + const ErrCodeInvalidArgumentForFunction + const ErrCodeInvalidBinaryRepresentation + const ErrCodeInvalidCast + const ErrCodeInvalidColumnReference + const ErrCodeInvalidContinuation + const ErrCodeInvalidCursorState + const ErrCodeInvalidDatabase + const ErrCodeInvalidFunctionDefinition + const ErrCodeInvalidName + const ErrCodeInvalidParameter + const ErrCodeInvalidPath + const ErrCodeInvalidPreparedStatementParameter + const ErrCodeInvalidRecursion + const ErrCodeInvalidRowCountInLimitClause + const ErrCodeInvalidSchemaTemplate + const ErrCodeInvalidTableDefinition + const ErrCodeInvalidTransactionState + const ErrCodeNoResultSet + const ErrCodeNotNullViolation + const ErrCodeNumericValueOutOfRange + const ErrCodePlanComplexityLimitReached + const ErrCodeSchemaAlreadyExists + const ErrCodeSchemaMappingAlreadyExists + const ErrCodeSerializationFailure + const ErrCodeStatementClosed + const ErrCodeStatementCompletionUnknown + const ErrCodeSuccess + const ErrCodeSyntaxError + const ErrCodeSyntaxOrAccessViolation + const ErrCodeTableAlreadyExists + const ErrCodeTooManyColumns + const ErrCodeTransactionInactive + const ErrCodeTransactionTimeout + const ErrCodeUnableToEstablishSQLConnection + const ErrCodeUndefinedColumn + const ErrCodeUndefinedDatabase + const ErrCodeUndefinedFile + const ErrCodeUndefinedFunction + const ErrCodeUndefinedIndex + const ErrCodeUndefinedParameter + const ErrCodeUndefinedSchema + const ErrCodeUndefinedTable + const ErrCodeUnionIncompatibleColumns + const ErrCodeUnionIncorrectColumnCount + const ErrCodeUniqueConstraintViolation + const ErrCodeUnknown + const ErrCodeUnknownDatabase + const ErrCodeUnknownSchemaTemplate + const ErrCodeUnknownType + const ErrCodeUnsupportedOperation + const ErrCodeUnsupportedQuery + const ErrCodeUnsupportedSort + const ErrCodeWindowingError + const ErrCodeWrongObjectType + func ErrorCodeFromString(s string) ErrorCode + func (c ErrorCode) Class() string + func (c ErrorCode) String() string + type FloatType struct + func NewFloatType(isNullable bool) *FloatType + func (b FloatType) Code() Code + func (b FloatType) IsNullable() bool + func (b FloatType) IsPrimitive() bool + func (t *FloatType) Equal(other DataType) bool + func (t *FloatType) IsResolved() bool + func (t *FloatType) Resolve(_ map[string]Named) DataType + func (t *FloatType) String() string + func (t *FloatType) WithNullable(isNullable bool) DataType + type Index interface + IndexType func() string + IsSparse func() bool + IsUnique func() bool + TableName func() string + type IndexFetchMethod int + const IndexFetchScanAndFetch + const IndexFetchUseRemoteFetch + const IndexFetchUseRemoteFetchWithFallback + func (m IndexFetchMethod) String() string + type IntegerType struct + func NewIntegerType(isNullable bool) *IntegerType + func (b IntegerType) Code() Code + func (b IntegerType) IsNullable() bool + func (b IntegerType) IsPrimitive() bool + func (t *IntegerType) Equal(other DataType) bool + func (t *IntegerType) IsResolved() bool + func (t *IntegerType) Resolve(_ map[string]Named) DataType + func (t *IntegerType) String() string + func (t *IntegerType) WithNullable(isNullable bool) DataType + type InvokedRoutine interface + type KeySet struct + func EmptyKeySet() *KeySet + func NewKeySet() *KeySet + func (k *KeySet) NumColumns() int + func (k *KeySet) SetKeyColumn(columnName string, value any) (*KeySet, error) + func (k *KeySet) SetKeyColumns(keyMap map[string]any) (*KeySet, error) + func (k *KeySet) ToMap() map[string]any + type LongType struct + func NewLongType(isNullable bool) *LongType + func (b LongType) Code() Code + func (b LongType) IsNullable() bool + func (b LongType) IsPrimitive() bool + func (t *LongType) Equal(other DataType) bool + func (t *LongType) IsResolved() bool + func (t *LongType) Resolve(_ map[string]Named) DataType + func (t *LongType) String() string + func (t *LongType) WithNullable(isNullable bool) DataType + type Metadata interface + Accept func(v Visitor) + MetadataName func() string + type MockColumn struct + func NewMockColumn(ctrl *gomock.Controller) *MockColumn + func (m *MockColumn) Accept(v Visitor) + func (m *MockColumn) DataType() DataType + func (m *MockColumn) EXPECT() *MockColumnMockRecorder + func (m *MockColumn) MetadataName() string + type MockColumnMockRecorder struct + func (mr *MockColumnMockRecorder) Accept(v any) *gomock.Call + func (mr *MockColumnMockRecorder) DataType() *gomock.Call + func (mr *MockColumnMockRecorder) MetadataName() *gomock.Call + type MockIndex struct + func NewMockIndex(ctrl *gomock.Controller) *MockIndex + func (m *MockIndex) Accept(v Visitor) + func (m *MockIndex) EXPECT() *MockIndexMockRecorder + func (m *MockIndex) IndexType() string + func (m *MockIndex) IsSparse() bool + func (m *MockIndex) IsUnique() bool + func (m *MockIndex) MetadataName() string + func (m *MockIndex) TableName() string + type MockIndexMockRecorder struct + func (mr *MockIndexMockRecorder) Accept(v any) *gomock.Call + func (mr *MockIndexMockRecorder) IndexType() *gomock.Call + func (mr *MockIndexMockRecorder) IsSparse() *gomock.Call + func (mr *MockIndexMockRecorder) IsUnique() *gomock.Call + func (mr *MockIndexMockRecorder) MetadataName() *gomock.Call + func (mr *MockIndexMockRecorder) TableName() *gomock.Call + type MockInvokedRoutine struct + func NewMockInvokedRoutine(ctrl *gomock.Controller) *MockInvokedRoutine + func (m *MockInvokedRoutine) Accept(v Visitor) + func (m *MockInvokedRoutine) EXPECT() *MockInvokedRoutineMockRecorder + func (m *MockInvokedRoutine) MetadataName() string + type MockInvokedRoutineMockRecorder struct + func (mr *MockInvokedRoutineMockRecorder) Accept(v any) *gomock.Call + func (mr *MockInvokedRoutineMockRecorder) MetadataName() *gomock.Call + type MockMetadata struct + func NewMockMetadata(ctrl *gomock.Controller) *MockMetadata + func (m *MockMetadata) Accept(v Visitor) + func (m *MockMetadata) EXPECT() *MockMetadataMockRecorder + func (m *MockMetadata) MetadataName() string + type MockMetadataMockRecorder struct + func (mr *MockMetadataMockRecorder) Accept(v any) *gomock.Call + func (mr *MockMetadataMockRecorder) MetadataName() *gomock.Call + type MockResultSet struct + func NewMockResultSet(ctrl *gomock.Controller) *MockResultSet + func (m *MockResultSet) Boolean(columnIndex int) (bool, error) + func (m *MockResultSet) BooleanByName(columnName string) (bool, error) + func (m *MockResultSet) Bytes(columnIndex int) ([]byte, error) + func (m *MockResultSet) BytesByName(columnName string) ([]byte, error) + func (m *MockResultSet) Close() error + func (m *MockResultSet) Continuation() (Continuation, error) + func (m *MockResultSet) Double(columnIndex int) (float64, error) + func (m *MockResultSet) EXPECT() *MockResultSetMockRecorder + func (m *MockResultSet) Err() error + func (m *MockResultSet) Float(columnIndex int) (float32, error) + func (m *MockResultSet) Long(columnIndex int) (int64, error) + func (m *MockResultSet) LongByName(columnName string) (int64, error) + func (m *MockResultSet) MetaData() ResultSetMetaData + func (m *MockResultSet) Next() bool + func (m *MockResultSet) Object(columnIndex int) (any, error) + func (m *MockResultSet) ObjectByName(columnName string) (any, error) + func (m *MockResultSet) String(columnIndex int) (string, error) + func (m *MockResultSet) StringByName(columnName string) (string, error) + func (m *MockResultSet) WasNull() bool + type MockResultSetMetaData struct + func NewMockResultSetMetaData(ctrl *gomock.Controller) *MockResultSetMetaData + func (m *MockResultSetMetaData) ColumnCount() int + func (m *MockResultSetMetaData) ColumnDataType(columnIndex int) (DataType, error) + func (m *MockResultSetMetaData) ColumnLabel(columnIndex int) (string, error) + func (m *MockResultSetMetaData) ColumnName(columnIndex int) (string, error) + func (m *MockResultSetMetaData) ColumnNullable(columnIndex int) (int, error) + func (m *MockResultSetMetaData) ColumnType(columnIndex int) (int, error) + func (m *MockResultSetMetaData) ColumnTypeName(columnIndex int) (string, error) + func (m *MockResultSetMetaData) EXPECT() *MockResultSetMetaDataMockRecorder + type MockResultSetMetaDataMockRecorder struct + func (mr *MockResultSetMetaDataMockRecorder) ColumnCount() *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnDataType(columnIndex any) *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnLabel(columnIndex any) *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnName(columnIndex any) *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnNullable(columnIndex any) *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnType(columnIndex any) *gomock.Call + func (mr *MockResultSetMetaDataMockRecorder) ColumnTypeName(columnIndex any) *gomock.Call + type MockResultSetMockRecorder struct + func (mr *MockResultSetMockRecorder) Boolean(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) BooleanByName(columnName any) *gomock.Call + func (mr *MockResultSetMockRecorder) Bytes(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) BytesByName(columnName any) *gomock.Call + func (mr *MockResultSetMockRecorder) Close() *gomock.Call + func (mr *MockResultSetMockRecorder) Continuation() *gomock.Call + func (mr *MockResultSetMockRecorder) Double(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) Err() *gomock.Call + func (mr *MockResultSetMockRecorder) Float(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) Long(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) LongByName(columnName any) *gomock.Call + func (mr *MockResultSetMockRecorder) MetaData() *gomock.Call + func (mr *MockResultSetMockRecorder) Next() *gomock.Call + func (mr *MockResultSetMockRecorder) Object(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) ObjectByName(columnName any) *gomock.Call + func (mr *MockResultSetMockRecorder) String(columnIndex any) *gomock.Call + func (mr *MockResultSetMockRecorder) StringByName(columnName any) *gomock.Call + func (mr *MockResultSetMockRecorder) WasNull() *gomock.Call + type MockSchema struct + func NewMockSchema(ctrl *gomock.Controller) *MockSchema + func (m *MockSchema) Accept(v Visitor) + func (m *MockSchema) DatabaseName() string + func (m *MockSchema) EXPECT() *MockSchemaMockRecorder + func (m *MockSchema) Indexes() (map[string][]string, error) + func (m *MockSchema) InvokedRoutines() ([]InvokedRoutine, error) + func (m *MockSchema) MetadataName() string + func (m *MockSchema) SchemaTemplate() SchemaTemplate + func (m *MockSchema) Tables() ([]Table, error) + func (m *MockSchema) Views() ([]View, error) + type MockSchemaMockRecorder struct + func (mr *MockSchemaMockRecorder) Accept(v any) *gomock.Call + func (mr *MockSchemaMockRecorder) DatabaseName() *gomock.Call + func (mr *MockSchemaMockRecorder) Indexes() *gomock.Call + func (mr *MockSchemaMockRecorder) InvokedRoutines() *gomock.Call + func (mr *MockSchemaMockRecorder) MetadataName() *gomock.Call + func (mr *MockSchemaMockRecorder) SchemaTemplate() *gomock.Call + func (mr *MockSchemaMockRecorder) Tables() *gomock.Call + func (mr *MockSchemaMockRecorder) Views() *gomock.Call + type MockSchemaTemplate struct + func NewMockSchemaTemplate(ctrl *gomock.Controller) *MockSchemaTemplate + func (m *MockSchemaTemplate) Accept(v Visitor) + func (m *MockSchemaTemplate) EXPECT() *MockSchemaTemplateMockRecorder + func (m *MockSchemaTemplate) EnableLongRows() bool + func (m *MockSchemaTemplate) FindInvokedRoutine(name string) (InvokedRoutine, error) + func (m *MockSchemaTemplate) FindTable(name string) (Table, error) + func (m *MockSchemaTemplate) FindView(name string) (View, error) + func (m *MockSchemaTemplate) GenerateSchema(databaseID, schemaName string) Schema + func (m *MockSchemaTemplate) Indexes() ([]string, error) + func (m *MockSchemaTemplate) IntermingleTables() bool + func (m *MockSchemaTemplate) InvokedRoutines() ([]InvokedRoutine, error) + func (m *MockSchemaTemplate) MetadataName() string + func (m *MockSchemaTemplate) StoreRowVersions() bool + func (m *MockSchemaTemplate) TableIndexMapping() (map[string][]string, error) + func (m *MockSchemaTemplate) Tables() ([]Table, error) + func (m *MockSchemaTemplate) TemporaryInvokedRoutines() ([]InvokedRoutine, error) + func (m *MockSchemaTemplate) TransactionBoundMetadataAsString() (string, error) + func (m *MockSchemaTemplate) Version() int + func (m *MockSchemaTemplate) Views() ([]View, error) + type MockSchemaTemplateMockRecorder struct + func (mr *MockSchemaTemplateMockRecorder) Accept(v any) *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) EnableLongRows() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) FindInvokedRoutine(name any) *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) FindTable(name any) *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) FindView(name any) *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) GenerateSchema(databaseID, schemaName any) *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) Indexes() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) IntermingleTables() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) InvokedRoutines() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) MetadataName() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) StoreRowVersions() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) TableIndexMapping() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) Tables() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) TemporaryInvokedRoutines() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) TransactionBoundMetadataAsString() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) Version() *gomock.Call + func (mr *MockSchemaTemplateMockRecorder) Views() *gomock.Call + type MockTable struct + func NewMockTable(ctrl *gomock.Controller) *MockTable + func (m *MockTable) Accept(v Visitor) + func (m *MockTable) Columns() []Column + func (m *MockTable) EXPECT() *MockTableMockRecorder + func (m *MockTable) Indexes() []Index + func (m *MockTable) MetadataName() string + func (m *MockTable) StructDataType() *StructType + type MockTableMockRecorder struct + func (mr *MockTableMockRecorder) Accept(v any) *gomock.Call + func (mr *MockTableMockRecorder) Columns() *gomock.Call + func (mr *MockTableMockRecorder) Indexes() *gomock.Call + func (mr *MockTableMockRecorder) MetadataName() *gomock.Call + func (mr *MockTableMockRecorder) StructDataType() *gomock.Call + type MockTransaction struct + func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction + func (m *MockTransaction) Abort() error + func (m *MockTransaction) BoundSchemaTemplate() SchemaTemplate + func (m *MockTransaction) Close() error + func (m *MockTransaction) Commit() error + func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder + func (m *MockTransaction) IsClosed() bool + func (m *MockTransaction) SetBoundSchemaTemplate(template SchemaTemplate) + func (m *MockTransaction) UnsetBoundSchemaTemplate() + func (m *MockTransaction) Unwrap() any + type MockTransactionMockRecorder struct + func (mr *MockTransactionMockRecorder) Abort() *gomock.Call + func (mr *MockTransactionMockRecorder) BoundSchemaTemplate() *gomock.Call + func (mr *MockTransactionMockRecorder) Close() *gomock.Call + func (mr *MockTransactionMockRecorder) Commit() *gomock.Call + func (mr *MockTransactionMockRecorder) IsClosed() *gomock.Call + func (mr *MockTransactionMockRecorder) SetBoundSchemaTemplate(template any) *gomock.Call + func (mr *MockTransactionMockRecorder) UnsetBoundSchemaTemplate() *gomock.Call + func (mr *MockTransactionMockRecorder) Unwrap() *gomock.Call + type MockView struct + func NewMockView(ctrl *gomock.Controller) *MockView + func (m *MockView) Accept(v Visitor) + func (m *MockView) EXPECT() *MockViewMockRecorder + func (m *MockView) MetadataName() string + type MockViewMockRecorder struct + func (mr *MockViewMockRecorder) Accept(v any) *gomock.Call + func (mr *MockViewMockRecorder) MetadataName() *gomock.Call + type MockVisitor struct + func NewMockVisitor(ctrl *gomock.Controller) *MockVisitor + func (m *MockVisitor) EXPECT() *MockVisitorMockRecorder + func (m *MockVisitor) FinishVisitSchemaTemplate(s SchemaTemplate) + func (m *MockVisitor) StartVisitSchemaTemplate(s SchemaTemplate) + func (m *MockVisitor) VisitColumn(c Column) + func (m *MockVisitor) VisitIndex(i Index) + func (m *MockVisitor) VisitInvokedRoutine(r InvokedRoutine) + func (m *MockVisitor) VisitSchema(s Schema) + func (m *MockVisitor) VisitSchemaTemplate(s SchemaTemplate) + func (m *MockVisitor) VisitTable(t Table) + func (m *MockVisitor) VisitView(v View) + type MockVisitorMockRecorder struct + func (mr *MockVisitorMockRecorder) FinishVisitSchemaTemplate(s any) *gomock.Call + func (mr *MockVisitorMockRecorder) StartVisitSchemaTemplate(s any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitColumn(c any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitIndex(i any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitInvokedRoutine(r any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitSchema(s any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitSchemaTemplate(s any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitTable(t any) *gomock.Call + func (mr *MockVisitorMockRecorder) VisitView(v any) *gomock.Call + type Named interface + Name func() string + type NullType struct + func NewNullType() *NullType + func (*NullType) Equal(other DataType) bool + func (b NullType) Code() Code + func (b NullType) IsNullable() bool + func (b NullType) IsPrimitive() bool + func (t *NullType) IsResolved() bool + func (t *NullType) Resolve(_ map[string]Named) DataType + func (t *NullType) String() string + func (t *NullType) WithNullable(isNullable bool) DataType + type OptionName string + const OptAsyncOperationsTimeoutMillis + const OptCaseSensitiveIdentifiers + const OptCompressWhenSerializing + const OptContinuation + const OptCurrentPlanHashMode + const OptDisablePlannerRewriting + const OptDisabledPlannerRules + const OptDryRun + const OptEncryptWhenSerializing + const OptEncryptionKeyEntry + const OptEncryptionKeyEntryList + const OptEncryptionKeyPassword + const OptEncryptionKeyStore + const OptExecutionScannedBytesLimit + const OptExecutionScannedRowsLimit + const OptExecutionTimeLimit + const OptIndexFetchMethod + const OptIndexHint + const OptLogQuery + const OptLogSlowQueryThresholdMicros + const OptMaxRows + const OptMaxStatementMemoryBytes + const OptPlanCachePrimaryMaxEntries + const OptPlanCachePrimaryTimeToLiveMillis + const OptPlanCacheSecondaryMaxEntries + const OptPlanCacheSecondaryTimeToLiveMillis + const OptPlanCacheTertiaryMaxEntries + const OptPlanCacheTertiaryTimeToLiveMillis + const OptPlanRightDeep + const OptPlannerStatistics + const OptReplaceOnDuplicatePK + const OptRequiredMetadataTableVersion + const OptRestrictDDLToSessionDatabase + const OptTransactionTags + const OptTransactionTimeout + const OptValidPlanHashModes + type Options struct + func NoOptions() *Options + func (o *Options) AllEntries() map[OptionName]any + func (o *Options) Entries() map[OptionName]any + func (o *Options) Equal(other *Options) bool + func (o *Options) Get(name OptionName) any + func (o *Options) With(name OptionName, value any) *Options + func (o *Options) WithChild(child *Options) (*Options, error) + type OptionsBuilder struct + func NewOptionsBuilder() *OptionsBuilder + func (b *OptionsBuilder) Build() *Options + func (b *OptionsBuilder) From(o *Options) *OptionsBuilder + func (b *OptionsBuilder) Set(name OptionName, value any) *OptionsBuilder + type ParseTreeInfo interface + QueryType func() QueryType + type PreparedStatement interface + ClearParameters func() error + ExecuteQueryPrepared func(ctx context.Context) (ResultSet, error) + ExecuteUpdatePrepared func(ctx context.Context) (int64, error) + SetObject func(parameterIndex int, value any) error + type QueryType int + const QueryTypeCreate + const QueryTypeDelete + const QueryTypeInsert + const QueryTypeSelect + const QueryTypeUpdate + func (q QueryType) String() string + type ResultSet interface + Boolean func(columnIndex int) (bool, error) + BooleanByName func(columnName string) (bool, error) + Bytes func(columnIndex int) ([]byte, error) + BytesByName func(columnName string) ([]byte, error) + Close func() error + Continuation func() (Continuation, error) + Double func(columnIndex int) (float64, error) + Err func() error + Float func(columnIndex int) (float32, error) + Long func(columnIndex int) (int64, error) + LongByName func(columnName string) (int64, error) + MetaData func() ResultSetMetaData + Next func() bool + Object func(columnIndex int) (any, error) + ObjectByName func(columnName string) (any, error) + String func(columnIndex int) (string, error) + StringByName func(columnName string) (string, error) + WasNull func() bool + type ResultSetMetaData interface + ColumnCount func() int + ColumnDataType func(columnIndex int) (DataType, error) + ColumnLabel func(columnIndex int) (string, error) + ColumnName func(columnIndex int) (string, error) + ColumnNullable func(columnIndex int) (int, error) + ColumnType func(columnIndex int) (int, error) + ColumnTypeName func(columnIndex int) (string, error) + type Row interface + Array func(position int) (RowIterable, error) + Bytes func(position int) ([]byte, error) + Double func(position int) (float64, error) + Float func(position int) (float32, error) + Long func(position int) (int64, error) + NumFields func() int + Object func(position int) (any, error) + Prefix func(length int) Row + Row func(position int) (Row, error) + StartsWith func(prefix Row) bool + String func(position int) (string, error) + type RowIterable interface + Close func() error + Next func() bool + Row func() Row + type SQLTypeName string + const SQLTypeNameArray + const SQLTypeNameBigInt + const SQLTypeNameBinary + const SQLTypeNameBoolean + const SQLTypeNameDate + const SQLTypeNameDouble + const SQLTypeNameFloat + const SQLTypeNameInteger + const SQLTypeNameNull + const SQLTypeNameOther + const SQLTypeNameString + const SQLTypeNameStruct + const SQLTypeNameTimestamp + func SQLTypeNameFromJDBC(jdbcCode int) SQLTypeName + type Schema interface + DatabaseName func() string + Indexes func() (map[string][]string, error) + InvokedRoutines func() ([]InvokedRoutine, error) + SchemaTemplate func() SchemaTemplate + Tables func() ([]Table, error) + Views func() ([]View, error) + type SchemaTemplate interface + EnableLongRows func() bool + FindInvokedRoutine func(name string) (InvokedRoutine, error) + FindTable func(name string) (Table, error) + FindView func(name string) (View, error) + GenerateSchema func(databaseID, schemaName string) Schema + Indexes func() ([]string, error) + IntermingleTables func() bool + InvokedRoutines func() ([]InvokedRoutine, error) + StoreRowVersions func() bool + TableIndexMapping func() (map[string][]string, error) + Tables func() ([]Table, error) + TemporaryInvokedRoutines func() ([]InvokedRoutine, error) + TransactionBoundMetadataAsString func() (string, error) + Version func() int + Views func() ([]View, error) + type SchemaTemplateCatalog interface + CreateTemplate func(txn Transaction, newTemplate SchemaTemplate) error + DeleteTemplate func(txn Transaction, templateName string, throwIfDoesNotExist bool) error + DeleteTemplateVersion func(txn Transaction, templateName string, version int, throwIfDoesNotExist bool) error + DoesSchemaTemplateExist func(txn Transaction, templateName string) (bool, error) + DoesSchemaTemplateExistAtVersion func(txn Transaction, templateName string, version int) (bool, error) + ListTemplates func(txn Transaction) (ResultSet, error) + LoadSchemaTemplate func(txn Transaction, templateName string) (SchemaTemplate, error) + LoadSchemaTemplateAtVersion func(txn Transaction, templateName string, version int) (SchemaTemplate, error) + type SchemaTemplateDDLRestrictedError struct + Operation string + SessionDatabase string + func (e *SchemaTemplateDDLRestrictedError) Error() string + type Statement interface + Close func() error + Execute func(ctx context.Context, sql string) (bool, error) + ExecuteQuery func(ctx context.Context, sql string) (ResultSet, error) + ExecuteUpdate func(ctx context.Context, sql string) (int64, error) + IsClosed func() bool + ResultSet func() ResultSet + UpdateCount func() int64 + type StoreCatalog interface + CreateDatabase func(txn Transaction, dbURI string) error + DeleteDatabase func(txn Transaction, dbURI string, throwIfDoesNotExist bool) (bool, error) + DeleteSchema func(txn Transaction, dbURI, schemaName string) error + DoesDatabaseExist func(txn Transaction, dbURI string) (bool, error) + DoesSchemaExist func(txn Transaction, dbURI, schemaName string) (bool, error) + ListDatabases func(txn Transaction, continuation Continuation) (ResultSet, error) + ListSchemas func(txn Transaction, continuation Continuation) (ResultSet, error) + ListSchemasInDatabase func(txn Transaction, databaseID string, continuation Continuation) (ResultSet, error) + LoadSchema func(txn Transaction, databaseID, schemaName string) (Schema, error) + RepairSchema func(txn Transaction, databaseID, schemaName string) error + SaveSchema func(txn Transaction, dataToWrite Schema, createDatabaseIfNecessary bool) error + SchemaTemplateCatalog func() SchemaTemplateCatalog + type StringType struct + func NewStringType(isNullable bool) *StringType + func (b StringType) Code() Code + func (b StringType) IsNullable() bool + func (b StringType) IsPrimitive() bool + func (t *StringType) Equal(other DataType) bool + func (t *StringType) IsResolved() bool + func (t *StringType) Resolve(_ map[string]Named) DataType + func (t *StringType) String() string + func (t *StringType) WithNullable(isNullable bool) DataType + type Struct interface + Attribute func(oneBasedIndex int) (any, error) + AttributeByName func(name string) (any, error) + AttributeCount func() int + Attributes func() []any + MetaData func() StructMetaData + type StructField struct + func NewStructField(name string, typ DataType, index int) StructField + func (f StructField) Equal(o StructField) bool + func (f StructField) Index() int + func (f StructField) Name() string + func (f StructField) String() string + func (f StructField) Type() DataType + type StructMetaData interface + AttributeCount func() int + AttributeDataType func(oneBasedIndex int) (DataType, error) + AttributeName func(oneBasedIndex int) (string, error) + AttributeNullable func(oneBasedIndex int) (int, error) + AttributeType func(oneBasedIndex int) (int, error) + AttributeTypeName func(oneBasedIndex int) (string, error) + TypeName func() string + type StructType struct + func NewStructType(name string, fields []StructField, isNullable bool) *StructType + func (b StructType) Code() Code + func (b StructType) IsNullable() bool + func (b StructType) IsPrimitive() bool + func (t *StructType) Equal(other DataType) bool + func (t *StructType) Field(i int) StructField + func (t *StructType) Fields() []StructField + func (t *StructType) HasIdenticalStructure(other any) bool + func (t *StructType) IsResolved() bool + func (t *StructType) Name() string + func (t *StructType) NumFields() int + func (t *StructType) Resolve(resolution map[string]Named) DataType + func (t *StructType) String() string + func (t *StructType) WithNullable(isNullable bool) DataType + type Table interface + Columns func() []Column + Indexes func() []Index + StructDataType func() *StructType + type TimeLimitSource string + const TimeLimitFDBTooOld + const TimeLimitPreempted + type TimestampType struct + func NewTimestampType(isNullable bool) *TimestampType + func (b TimestampType) Code() Code + func (b TimestampType) IsNullable() bool + func (b TimestampType) IsPrimitive() bool + func (t *TimestampType) Equal(other DataType) bool + func (t *TimestampType) IsResolved() bool + func (t *TimestampType) Resolve(_ map[string]Named) DataType + func (t *TimestampType) String() string + func (t *TimestampType) WithNullable(isNullable bool) DataType + type Transaction interface + Abort func() error + BoundSchemaTemplate func() SchemaTemplate + Close func() error + Commit func() error + IsClosed func() bool + SetBoundSchemaTemplate func(template SchemaTemplate) + UnsetBoundSchemaTemplate func() + Unwrap func() any + type TransactionTimeLimitError struct + Elapsed time.Duration + Limit time.Duration + Source TimeLimitSource + func (e *TransactionTimeLimitError) Error() string + func (e *TransactionTimeLimitError) Unwrap() error + type UUIDType struct + func NewUUIDType(isNullable bool) *UUIDType + func (b UUIDType) Code() Code + func (b UUIDType) IsNullable() bool + func (b UUIDType) IsPrimitive() bool + func (t *UUIDType) Equal(other DataType) bool + func (t *UUIDType) IsResolved() bool + func (t *UUIDType) Resolve(_ map[string]Named) DataType + func (t *UUIDType) String() string + func (t *UUIDType) WithNullable(isNullable bool) DataType + type UnknownType struct + func NewUnknownType() *UnknownType + func (b UnknownType) Code() Code + func (b UnknownType) IsNullable() bool + func (b UnknownType) IsPrimitive() bool + func (t *UnknownType) Equal(other DataType) bool + func (t *UnknownType) IsResolved() bool + func (t *UnknownType) Resolve(_ map[string]Named) DataType + func (t *UnknownType) String() string + func (t *UnknownType) WithNullable(bool) DataType + type UnresolvedType struct + func NewUnresolvedType(name string, isNullable bool) *UnresolvedType + func (b UnresolvedType) Code() Code + func (b UnresolvedType) IsNullable() bool + func (b UnresolvedType) IsPrimitive() bool + func (t *UnresolvedType) Equal(other DataType) bool + func (t *UnresolvedType) IsResolved() bool + func (t *UnresolvedType) Name() string + func (t *UnresolvedType) Resolve(resolution map[string]Named) DataType + func (t *UnresolvedType) String() string + func (t *UnresolvedType) WithNullable(isNullable bool) DataType + type VectorType struct + func NewVectorType(precision, dimensions int, isNullable bool) *VectorType + func (b VectorType) Code() Code + func (b VectorType) IsNullable() bool + func (b VectorType) IsPrimitive() bool + func (t *VectorType) Dimensions() int + func (t *VectorType) Equal(other DataType) bool + func (t *VectorType) IsResolved() bool + func (t *VectorType) Precision() int + func (t *VectorType) Resolve(_ map[string]Named) DataType + func (t *VectorType) String() string + func (t *VectorType) WithNullable(isNullable bool) DataType + type VersionType struct + func NewVersionType(isNullable bool) *VersionType + func (b VersionType) Code() Code + func (b VersionType) IsNullable() bool + func (b VersionType) IsPrimitive() bool + func (t *VersionType) Equal(other DataType) bool + func (t *VersionType) IsResolved() bool + func (t *VersionType) Resolve(_ map[string]Named) DataType + func (t *VersionType) String() string + func (t *VersionType) WithNullable(isNullable bool) DataType + type View interface + type Visitor interface + FinishVisitSchemaTemplate func(s SchemaTemplate) + StartVisitSchemaTemplate func(s SchemaTemplate) + VisitColumn func(c Column) + VisitIndex func(i Index) + VisitInvokedRoutine func(r InvokedRoutine) + VisitSchema func(s Schema) + VisitSchemaTemplate func(s SchemaTemplate) + VisitTable func(t Table) + VisitView func(v View) + type WithMetadata interface + RelationalMetaData func() (DataType, error)
Go to main page