m2o

package
v1.0.9 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2023 License: Apache-2.0 Imports: 20 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.

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 GenCompatibilityTable 

func GenCompatibilityTable(f *reverse.File, sourceSchema string, errCompatibility map[string][]map[string]string, viewTables []string) error

func GenCreateSchema 

func GenCreateSchema(f *reverse.File, sourceSchema, targetSchema string) error

func IChanger added in v1.0.8 

func IChanger(c reverse.Changer) (map[string]string, map[string]map[string]string, map[string]map[string]string, error)

func IWriter 

func IWriter(f *reverse.File, w reverse.Writer) error

func LoadColumnDefaultValueRule added in v1.0.9 

func LoadColumnDefaultValueRule(columnName string, defaultValue string, columnDefaultValueMapSlice []meta.BuildinColumnDefaultval, globalDefaultValueMapSlice []meta.BuildinGlobalDefaultval) string

func LoadDataTypeRuleUsingTableOrSchema added in v1.0.9 

func LoadDataTypeRuleUsingTableOrSchema(originColumnType string, buildInColumnType string, tableDataTypeMapSlice []meta.TableDatatypeRule, schemaDataTypeMapSlice []meta.SchemaDatatypeRule) string

func MySQLTableColumnMapRule 

func MySQLTableColumnMapRule(sourceSchema, sourceTable string, column Column, buildinDatatypes []meta.BuildinDatatypeRule) (string, string, error)

MySQL 表字段映射转换 -> Reverse 阶段

func PreCheckCompatibility 

func PreCheckCompatibility(cfg *config.Config, mysql *mysql.MySQL, exporters []string, oracleDBVersion string, isExtended bool) ([]string, map[string][]map[string]string, map[string]string, map[string]string, error)

Types

type Change added in v1.0.8 

type Change struct {
	Ctx              context.Context `json:"-"`
	SourceSchemaName string          `json:"source_schema_name"`
	TargetSchemaName string          `json:"target_schema_name"`
	SourceTables     []string        `json:"source_tables"`
	Threads          int             `json:"threads"`
	MySQL            *mysql.MySQL    `json:"-"`
	MetaDB           *meta.Meta      `json:"-"`
}

func (*Change) ChangeTableColumnDatatype added in v1.0.8 

func (r *Change) ChangeTableColumnDatatype() (map[string]map[string]string, error)

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

func (*Change) ChangeTableColumnDefaultValue added in v1.0.8 

func (r *Change) ChangeTableColumnDefaultValue() (map[string]map[string]string, error)

func (*Change) ChangeTableName added in v1.0.8 

func (r *Change) ChangeTableName() (map[string]string, error)

type Column added in v1.0.8 

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

type ColumnInfo added in v1.0.8 

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

type DDL 

type DDL struct {
	SourceSchemaName     string   `json:"source_schema"`
	SourceTableName      string   `json:"source_table_name"`
	SourceTableType      string   `json:"source_table_type"`
	TargetSchemaName     string   `json:"target_schema"`
	TargetTableName      string   `json:"target_table_name"`
	TablePrefix          string   `json:"table_prefix"`
	TableColumns         []string `json:"table_columns"`
	TableKeys            []string `json:"table_keys"`
	TableIndexes         []string `json:"table_indexes"`
	TableSuffix          string   `json:"table_suffix"`
	TableComment         string   `json:"table_comment"`
	ColumnCommentDDL     []string `json:"column_comment_ddl"`
	TableCheckKeys       []string `json:"table_check_keys""`
	TableForeignKeys     []string `json:"table_foreign_keys"`
	TableCompatibleDDL   []string `json:"table_compatible_ddl"`
	TablePartitionDetail string   `json:"table_partition_detail"`
}

func IReverse 

func IReverse(s reverse.Generator) (*DDL, error)

func (*DDL) File added in v1.0.8 

func (d *DDL) File(f *reverse.File) error

func (*DDL) String added in v1.0.8 

func (d *DDL) String() string

type Info added in v1.0.8 

type Info struct {
	PrimaryKeyINFO       []map[string]string `json:"primary_key_info"`
	UniqueKeyINFO        []map[string]string `json:"unique_key_info"`
	ForeignKeyINFO       []map[string]string `json:"foreign_key_info"`
	CheckKeyINFO         []map[string]string `json:"check_key_info"`
	UniqueIndexINFO      []map[string]string `json:"unique_index_info"`
	NormalIndexINFO      []map[string]string `json:"normal_index_info"`
	TableCommentINFO     []map[string]string `json:"table_comment_info"`
	TableColumnINFO      []map[string]string `json:"table_column_info"`
	ColumnCommentINFO    []map[string]string `json:"column_comment_info"`
	TablePartitionDetail string              `json:"table_partition_detail"`
}

type Reverse added in v1.0.8 

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

func NewM2OReverse 

func NewM2OReverse(ctx context.Context, cfg *config.Config, mysql *mysql.MySQL, oracle *oracle.Oracle, metaDB *meta.Meta) *Reverse

func (*Reverse) NewReverse added in v1.0.8 

func (r *Reverse) NewReverse() error

type Rule 

type Rule struct {
	*Table
	*Info
}

func IReader 

func IReader(r reverse.Reader) (*Rule, error)

func (*Rule) GenCreateTableDDL 

func (r *Rule) GenCreateTableDDL() (interface{}, error)

func (*Rule) GenSchemaName added in v1.0.8 

func (r *Rule) GenSchemaName() string

func (*Rule) GenTableCheckKey 

func (r *Rule) GenTableCheckKey() (checkKeys []string, err error)

func (*Rule) GenTableColumn 

func (r *Rule) GenTableColumn() (columnMetas []string, err error)

func (*Rule) GenTableColumnComment 

func (r *Rule) GenTableColumnComment() (columnComments []string, err error)

func (*Rule) GenTableComment 

func (r *Rule) GenTableComment() (tableComment string, err error)

func (*Rule) GenTableForeignKey 

func (r *Rule) GenTableForeignKey() (foreignKeys []string, err error)

func (*Rule) GenTableKeys added in v1.0.8 

func (r *Rule) GenTableKeys() (tableKeyMetas []string, compatibilityIndexSQL []string, err error)

func (*Rule) GenTableName added in v1.0.8 

func (r *Rule) GenTableName() string

func (*Rule) GenTableNormalIndex 

func (r *Rule) GenTableNormalIndex() (normalIndexes []string, compatibilityIndexSQL []string, err error)

func (*Rule) GenTablePrefix 

func (r *Rule) GenTablePrefix() (string, string)

func (*Rule) GenTablePrimaryKey 

func (r *Rule) GenTablePrimaryKey() (primaryKeys []string, err error)

func (*Rule) GenTableSuffix added in v1.0.8 

func (r *Rule) GenTableSuffix() (string, error)

func (*Rule) GenTableUniqueIndex 

func (r *Rule) GenTableUniqueIndex() (uniqueIndexes []string, compatibilityIndexSQL []string, err error)

func (*Rule) GenTableUniqueKey 

func (r *Rule) GenTableUniqueKey() (uniqueKeys []string, err error)

func (*Rule) String 

func (r *Rule) String() string

type Table 

type Table struct {
	Ctx                     context.Context `json:"-"`
	MySQLDBType             string          `json:"mysqldb_type"`
	OracleDBVersion         string          `json:"oracle_db_version"`
	OracleExtendedMode      bool            `json:"oracle_extended_mode"`
	SourceSchemaName        string          `json:"source_schema_name"`
	TargetSchemaName        string          `json:"target_schema_name"`
	SourceTableName         string          `json:"source_table_name"`
	TargetTableName         string          `json:"target_table_name"`
	IsPartition             bool            `json:"is_partition"`
	SourceTableCharacterSet string          `json:"source_table_character_set"`
	SourceTableCollation    string          `json:"source_table_collation"`

	TableColumnDatatypeRule   map[string]string `json:"table_column_datatype_rule"`
	TableColumnDefaultValRule map[string]string `json:"table_column_default_val_rule"`
	Overwrite                 bool              `json:"overwrite"`
	Oracle                    *oracle.Oracle    `json:"-"`
	MySQL                     *mysql.MySQL      `json:"-"`
	MetaDB                    *meta.Meta        `json:"-"`
}

func GenReverseTableTask 

func GenReverseTableTask(r *Reverse, tableNameRule map[string]string, tableColumnRule, tableDefaultRule map[string]map[string]string, exporters []string, oracleDBVersion string, isExtended bool, tableCharSetMap map[string]string, tableCollationMap map[string]string) ([]*Table, error)

func (*Table) GetTableCheckKey 

func (t *Table) GetTableCheckKey() ([]map[string]string, error)

func (*Table) GetTableColumnComment 

func (t *Table) GetTableColumnComment() ([]map[string]string, error)

func (*Table) GetTableColumnMeta 

func (t *Table) GetTableColumnMeta() ([]map[string]string, error)

func (*Table) GetTableComment 

func (t *Table) GetTableComment() ([]map[string]string, error)

func (*Table) GetTableForeignKey 

func (t *Table) GetTableForeignKey() ([]map[string]string, error)

func (*Table) GetTableInfo added in v1.0.8 

func (t *Table) GetTableInfo() (interface{}, error)

func (*Table) GetTableNormalIndex 

func (t *Table) GetTableNormalIndex() ([]map[string]string, error)

func (*Table) GetTablePartitionDetail added in v1.0.8 

func (t *Table) GetTablePartitionDetail() (string, error)

func (*Table) GetTablePrimaryKey 

func (t *Table) GetTablePrimaryKey() ([]map[string]string, error)

func (*Table) GetTableUniqueIndex 

func (t *Table) GetTableUniqueIndex() ([]map[string]string, error)

func (*Table) GetTableUniqueKey 

func (t *Table) GetTableUniqueKey() ([]map[string]string, error)

func (*Table) String 

func (t *Table) 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.