connmysql

package
v0.0.0-...-bd61e48 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 5, 2026 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildQuery 

func BuildQuery(logger log.Logger, query string, start string, end string) (string, error)

func QRecordSchemaFromMysqlFields 

func QRecordSchemaFromMysqlFields(tableSchema *protos.TableSchema, fields []*mysql.Field) (types.QRecordSchema, error)

func QValueFromMysqlFieldValue 

func QValueFromMysqlFieldValue(qkind types.QValueKind, mytype byte, fv mysql.FieldValue) (types.QValue, error)

func QValueFromMysqlRowEvent 

func QValueFromMysqlRowEvent(
	ev *replication.TableMapEvent, idx int,
	enums []string, sets []string,
	qkind types.QValueKind, val any, logger log.Logger, coercionReported *bool,
) (types.QValue, error)

func QkindFromMysqlColumnType 

func QkindFromMysqlColumnType(ct string) (types.QValueKind, error)

Types

type MySqlConnector 

type MySqlConnector struct {
	*metadataStore.PostgresMetadata
	// contains filtered or unexported fields
}

func NewMySqlConnector 

func NewMySqlConnector(ctx context.Context, config *protos.MySqlConfig) (*MySqlConnector, error)

func (*MySqlConnector) CheckBinlogSettings 

func (c *MySqlConnector) CheckBinlogSettings(ctx context.Context, requireRowMetadata bool) error

func (*MySqlConnector) CheckReplicationConnectivity 

func (c *MySqlConnector) CheckReplicationConnectivity(ctx context.Context) error

func (*MySqlConnector) CheckSourceTables 

func (c *MySqlConnector) CheckSourceTables(ctx context.Context, tableNames []*common.QualifiedTable) error

func (*MySqlConnector) Close 

func (c *MySqlConnector) Close() error

func (*MySqlConnector) CompareServerVersion 

func (c *MySqlConnector) CompareServerVersion(ctx context.Context, version string) (int, error)

func (*MySqlConnector) ConnectionActive 

func (c *MySqlConnector) ConnectionActive(ctx context.Context) error

func (*MySqlConnector) Dialer 

func (c *MySqlConnector) Dialer() client.Dialer

func (*MySqlConnector) EnsurePullability 

func (c *MySqlConnector) EnsurePullability(
	ctx context.Context, req *protos.EnsurePullabilityBatchInput,
) (*protos.EnsurePullabilityBatchOutput, error)

func (*MySqlConnector) Execute 

func (c *MySqlConnector) Execute(ctx context.Context, cmd string, args ...any) (*mysql.Result, error)

func (*MySqlConnector) ExecuteSelectStreaming 

func (c *MySqlConnector) ExecuteSelectStreaming(ctx context.Context, cmd string, result *mysql.Result,
	rowCb client.SelectPerRowCallback,
	resultCb client.SelectPerResultCallback,
	args ...any,
) error

func (*MySqlConnector) ExportTxSnapshot 

func (c *MySqlConnector) ExportTxSnapshot(context.Context, string, map[string]string) (*protos.ExportTxSnapshotOutput, any, error)

func (*MySqlConnector) FinishExport 

func (c *MySqlConnector) FinishExport(any) error

func (*MySqlConnector) Flavor 

func (c *MySqlConnector) Flavor() string

func (*MySqlConnector) GetAllTables 

func (c *MySqlConnector) GetAllTables(ctx context.Context) (*protos.AllTablesResponse, error)

func (*MySqlConnector) GetColumns 

func (c *MySqlConnector) GetColumns(ctx context.Context, version uint32, schema string, table string) (*protos.TableColumnsResponse, error)

func (*MySqlConnector) GetDatabaseVariant 

func (c *MySqlConnector) GetDatabaseVariant(ctx context.Context) (protos.DatabaseVariant, error)

func (*MySqlConnector) GetDefaultPartitionKeyForTables 

func (c *MySqlConnector) GetDefaultPartitionKeyForTables(
	ctx context.Context,
	input *protos.GetDefaultPartitionKeyForTablesInput,
) (*protos.GetDefaultPartitionKeyForTablesOutput, error)

func (*MySqlConnector) GetGtidModeOn 

func (c *MySqlConnector) GetGtidModeOn(ctx context.Context) (bool, error)

func (*MySqlConnector) GetLogRetentionHours 

func (c *MySqlConnector) GetLogRetentionHours(ctx context.Context) (float64, error)

func (*MySqlConnector) GetMasterGTIDSet 

func (c *MySqlConnector) GetMasterGTIDSet(ctx context.Context) (mysql.GTIDSet, error)

func (*MySqlConnector) GetMasterPos 

func (c *MySqlConnector) GetMasterPos(ctx context.Context) (mysql.Position, error)

func (*MySqlConnector) GetQRepPartitions 

func (c *MySqlConnector) GetQRepPartitions(
	ctx context.Context,
	config *protos.QRepConfig,
	last *protos.QRepPartition,
) ([]*protos.QRepPartition, error)

func (*MySqlConnector) GetSchemas 

func (c *MySqlConnector) GetSchemas(ctx context.Context) (*protos.PeerSchemasResponse, error)

func (*MySqlConnector) GetTableSchema 

func (c *MySqlConnector) GetTableSchema(
	ctx context.Context,
	env map[string]string,
	version uint32,
	system protos.TypeSystem,
	tableMappings []*protos.TableMapping,
) (map[string]*protos.TableSchema, error)

func (*MySqlConnector) GetTableSizeEstimatedBytes 

func (c *MySqlConnector) GetTableSizeEstimatedBytes(ctx context.Context, tableIdentifier string) (int64, error)

func (*MySqlConnector) GetTablesInSchema 

func (c *MySqlConnector) GetTablesInSchema(
	ctx context.Context, schema string, cdcEnabled bool,
) (*protos.SchemaTablesResponse, error)

func (*MySqlConnector) GetVersion 

func (c *MySqlConnector) GetVersion(ctx context.Context) (string, error)

func (*MySqlConnector) PullFlowCleanup 

func (c *MySqlConnector) PullFlowCleanup(ctx context.Context, jobName string) error

func (*MySqlConnector) PullQRepRecords 

func (c *MySqlConnector) PullQRepRecords(
	ctx context.Context,
	otelManager *otel_metrics.OtelManager,
	config *protos.QRepConfig,
	dstType protos.DBType,
	partition *protos.QRepPartition,
	stream *model.QRecordStream,
) (int64, int64, error)

func (*MySqlConnector) PullRecords 

func (c *MySqlConnector) PullRecords(
	ctx context.Context,
	catalogPool shared.CatalogPool,
	otelManager *otel_metrics.OtelManager,
	req *model.PullRecordsRequest[model.RecordItems],
) error

func (*MySqlConnector) ReplPing 

func (c *MySqlConnector) ReplPing(context.Context) error

func (*MySqlConnector) SetupReplConn 

func (c *MySqlConnector) SetupReplConn(context.Context, map[string]string) error

func (*MySqlConnector) SetupReplication 

func (c *MySqlConnector) SetupReplication(
	ctx context.Context,
	req *protos.SetupReplicationInput,
) (model.SetupReplicationResult, error)

func (*MySqlConnector) StatActivity 

func (c *MySqlConnector) StatActivity(
	ctx context.Context,
	req *protos.PostgresPeerActivityInfoRequest,
) (*protos.PeerStatResponse, error)

func (*MySqlConnector) UpdateReplStateLastOffset 

func (c *MySqlConnector) UpdateReplStateLastOffset(ctx context.Context, lastOffset model.CdcCheckpoint) error

func (*MySqlConnector) ValidateCheck 

func (c *MySqlConnector) ValidateCheck(ctx context.Context) error

func (*MySqlConnector) ValidateMirrorSource 

func (c *MySqlConnector) ValidateMirrorSource(ctx context.Context, cfg *protos.FlowConnectionConfigsCore) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.