o2m

package
v1.0.11 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ChangeTableColumnDefaultValue 

func ChangeTableColumnDefaultValue(ctx context.Context, metaDB *meta.Meta, dbTypeS, dbTypeT, sourceSchema, sourceTableName, columnName, dataDefault string) (string, error)

func ChangeTableColumnType 

func ChangeTableColumnType(ctx context.Context, metaDB *meta.Meta, dbTypeS, dbTypeT, sourceSchema, sourceTableName, columnName string, columnINFO Column) (string, error)

数据库查询获取自定义表结构转换规则 加载数据类型转换规则【处理字段级别、表级别、库级别数据类型映射规则】 数据类型转换规则判断，未设置自定义规则，默认采用内置默认字段类型转换

func GenOracleTableColumnMeta 

func GenOracleTableColumnMeta(ctx context.Context, metaDB *meta.Meta, dbTypeS, dbTypeT, sourceSchema, sourceTableName, columnName string, columnINFO Column) (string, error)

Oracle 表字段映射转换 -> Check 阶段

func GetOracleConstraint 

func GetOracleConstraint(schemaName, tableName string, oracle *oracle.Oracle) ([]ConstraintPUKey, []ConstraintForeign, []ConstraintCheck, error)

func GetOracleTableColumn 

func GetOracleTableColumn(schemaName, tableName string, oracle *oracle.Oracle, sourceDBCharacterSet, nlsComp string,
	sourceTableCollation string, sourceSchemaCollation string, oraCollation bool) (map[string]Column, string, error)

func OracleTableColumnMapRuleCheck 

func OracleTableColumnMapRuleCheck(
	sourceSchema, targetSchema, tableName, columnName string,
	oracleColInfo, mysqlColInfo Column) (string, table.Row, error)

Types

type Check 

type Check struct {
	// contains filtered or unexported fields
}

func NewCheck added in v1.0.10 

func NewCheck(ctx context.Context, cfg *config.Config) (*Check, error)

func (*Check) Check added in v1.0.10 

func (r *Check) Check() error

type Column 

type Column struct {
	DataType                string
	CharLength              string
	CharUsed                string
	CharacterSet            string
	Collation               string
	OracleOriginDataDefault string
	MySQLOriginDataDefault  string
	ColumnInfo
}

func (*Column) String 

func (c *Column) String() string

type ColumnInfo 

type ColumnInfo struct {
	DataLength        string
	DataPrecision     string
	DataScale         string
	DatetimePrecision string
	NULLABLE          string
	DataDefault       string
	Comment           string
}

type ConstraintCheck 

type ConstraintCheck struct {
	ConstraintExpression string
}

type ConstraintForeign 

type ConstraintForeign struct {
	ColumnName            string
	ReferencedTableSchema string
	ReferencedTableName   string
	ReferencedColumnName  string
	DeleteRule            string
	UpdateRule            string
}

type ConstraintPUKey 

type ConstraintPUKey struct {
	ConstraintType   string
	ConstraintColumn string
}

type Diff added in v1.0.10 

type Diff struct {
	Ctx             context.Context
	DBTypeS         string     `json:"db_type_s"`
	DBTypeT         string     `json:"db_type_t"`
	OracleTableINFO *Table     `json:"oracle_table_info"`
	MySQLTableINFO  *Table     `json:"mysql_table_info"`
	MySQLDBVersion  string     `json:"mysqldb_version"`
	MySQLDBType     string     `json:"mysqldb_type"`
	MetaDB          *meta.Meta `json:"-"`
}

func NewChecker 

func NewChecker(ctx context.Context, oracleTableInfo, mysqlTableInfo *Table, dbTypeS, dbTypeT, mysqlDBVersion, targetDBType string, metaDB *meta.Meta) *Diff

func (*Diff) CheckCheckKey added in v1.0.10 

func (c *Diff) CheckCheckKey() (string, error)

func (*Diff) CheckColumn added in v1.0.10 

func (c *Diff) CheckColumn() (string, error)

func (*Diff) CheckColumnCharacterSetAndCollation added in v1.0.10 

func (c *Diff) CheckColumnCharacterSetAndCollation() string

func (*Diff) CheckColumnCounts added in v1.0.10 

func (c *Diff) CheckColumnCounts() (string, error)

func (*Diff) CheckForeignKey added in v1.0.10 

func (c *Diff) CheckForeignKey() (string, error)

func (*Diff) CheckIndex added in v1.0.10 

func (c *Diff) CheckIndex() (string, error)

func (*Diff) CheckPartitionTable added in v1.0.10 

func (c *Diff) CheckPartitionTable() (string, error)

func (*Diff) CheckPartitionTableType added in v1.0.10 

func (c *Diff) CheckPartitionTableType() string

func (*Diff) CheckPrimaryAndUniqueKey added in v1.0.10 

func (c *Diff) CheckPrimaryAndUniqueKey() (string, error)

func (*Diff) CheckTableCharacterSetAndCollation added in v1.0.10 

func (c *Diff) CheckTableCharacterSetAndCollation() string

func (*Diff) CheckTableComment added in v1.0.10 

func (c *Diff) CheckTableComment() string

func (*Diff) String added in v1.0.10 

func (c *Diff) String() string

func (*Diff) Writer added in v1.0.10 

func (c *Diff) Writer(f *check.File) error

type Index 

type Index struct {
	IndexInfo
	IndexName        string
	IndexType        string
	DomainIndexOwner string
	DomainIndexName  string
	DomainParameters string
}

func GetOracleTableIndex 

func GetOracleTableIndex(schemaName, tableName string, oracle *oracle.Oracle) ([]Index, error)

type IndexInfo 

type IndexInfo struct {
	Uniqueness  string
	IndexColumn string
}

type Partition 

type Partition struct {
	PartitionKey     string
	PartitionType    string
	SubPartitionKey  string
	SubPartitionType string
}

type Table 

type Table struct {
	SchemaName         string
	TableName          string
	TableComment       string
	TableCharacterSet  string
	TableCollation     string
	Columns            map[string]Column // KEY 字段名
	Indexes            []Index
	PUConstraints      []ConstraintPUKey
	ForeignConstraints []ConstraintForeign
	CheckConstraints   []ConstraintCheck
	IsPartition        bool
	Partitions         []Partition // 获取分区键、分区类型以及子分区键、子分区类型
}

func NewMySQLTableINFO 

func NewMySQLTableINFO(schemaName, tableName, targetDBType string, mysql *mysql.MySQL) (*Table, string, error)

func NewOracleTableINFO 

func NewOracleTableINFO(schemaName, tableName string, oracle *oracle.Oracle, sourceCharacterSet, nlsComp string,
	sourceTableCollation, sourceSchemaCollation string, oracleCollation bool) (*Table, error)

func (*Table) String 

func (t *Table) String(jsonType string) string

type Task 

type Task struct {
	SourceSchemaName      string `json:"source_schema_name"`
	TargetSchemaName      string `json:"target_schema_name"`
	SourceTableName       string `json:"source_table_name"`
	TargetTableName       string `json:"target_table_name"`
	TargetDBType          string `json:"target_db_type"`
	SourceDBCharacterSet  string `json:"source_db_character_set"`
	SourceDBNLSSort       string `json:"source_dbnls_sort"`
	SourceDBNLSComp       string `json:"source_dbnls_comp"`
	SourceDBCollation     bool   `json:"source_db_collation"`
	SourceTableCollation  string `json:"source_table_collation"`
	SourceSchemaCollation string `json:"source_schema_collation"`

	Oracle *oracle.Oracle `json:"-"`
	MySQL  *mysql.MySQL   `json:"-"`
}

func GenCheckTaskTable 

func GenCheckTaskTable(sourceSchemaName, targetSchemaName, sourceDBCharacterSet, nlsSort, nlsComp string,
	sourceTableCollation map[string]string, sourceSchemaCollation string,
	sourceDBCollation bool, targetDBType string, oracle *oracle.Oracle, mysql *mysql.MySQL, tableNameRule map[string]string, waitSyncMetas []meta.WaitSyncMeta) []*Task

func (*Task) GenMySQLTable 

func (t *Task) GenMySQLTable() (*Table, string, error)

func (*Task) GenOracleTable 

func (t *Task) GenOracleTable() (*Table, error)

func (*Task) String added in v1.0.10 

func (t *Task) String() string

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.