o2m

package
v1.0.6 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2022 License: Apache-2.0 Imports: 21 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 GenCompatibilityTable 

func GenCompatibilityTable(f *reverse.File, sourceSchema string, partitionTables, temporaryTables, clusteredTables []string) error

func GenCreateSchema 

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

func IWriter 

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

func OracleTableColumnMapRule 

func OracleTableColumnMapRule(sourceSchema, sourceTable string, column o2m.Column) (string, string, error)

Types

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"`
	TargetDBType     string   `json:"target_db_type"`
	TargetDBVersion  string   `json:"target_db_version"`
	ReverseDDL       string   `json:"reverse_ddl"`
	TableSuffix      string   `json:"table_suffix"`
	TableComment     string   `json:"table_comment"`
	CheckKeyDDL      []string `json:"check_key_ddl"`
	ForeignKeyDDL    []string `json:"foreign_key_ddl"`
	CompatibleDDL    []string `json:"compatible_ddl"`
}

func IReverse 

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

func (*DDL) Writer 

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

type O2M 

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

func NewO2MReverse 

func NewO2MReverse(ctx context.Context, cfg *config.Config, mysql *mysql.MySQL, oracle *oracle.Oracle) *O2M

func (*O2M) NewReverse 

func (o2m *O2M) NewReverse() error

type Rule 

type Rule struct {
	Ctx               context.Context     `json:"-"`
	SourceSchema      string              `json:"source_schema"`
	SourceTableName   string              `json:"source_table_name"`
	TargetSchema      string              `json:"target_schema"`
	TargetTableName   string              `json:"target_table_name"`
	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"`
	OracleCollation   bool                `json:"oracle_collation"`

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

func IReader 

func IReader(ctx context.Context, oracle *oracle.Oracle, t *Table, rd reverse.Reader) (*Rule, error)

func (*Rule) ChangeSchemaName 

func (r *Rule) ChangeSchemaName() string

func (*Rule) ChangeTableColumnDefaultValue 

func (r *Rule) ChangeTableColumnDefaultValue(dataDefault string) (string, error)

func (*Rule) ChangeTableColumnType 

func (r *Rule) ChangeTableColumnType(sourceSchema, sourceTable, sourceColumn string, column interface{}) (string, error)

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

func (*Rule) ChangeTableName 

func (r *Rule) ChangeTableName() string

func (*Rule) GenCreateTableDDL 

func (r *Rule) GenCreateTableDDL() (reverseDDL string, checkKeyDDL []string, foreignKeyDDL []string, compatibleDDL []string, err error)

func (*Rule) GenTableCheckKey 

func (r *Rule) GenTableCheckKey() (checkKeyMetas []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() (foreignKeyMetas []string, err error)

func (*Rule) GenTableKeyMeta 

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

func (*Rule) GenTableNormalIndex 

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

func (*Rule) GenTablePrefix 

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

func (*Rule) GenTablePrimaryKey 

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

func (*Rule) GenTableUniqueIndex 

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

func (*Rule) GenTableUniqueKey 

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

func (*Rule) String 

func (r *Rule) String() string

type Table 

type Table struct {
	Ctx                   context.Context `json:"-"`
	SourceSchemaName      string          `json:"source_schema_name"`
	TargetSchemaName      string          `json:"target_schema_name"`
	SourceTableName       string          `json:"source_table_name"`
	TargetDBType          string          `json:"target_db_type"`
	TargetDBVersion       string          `json:"target_db_version"`
	TargetTableName       string          `json:"target_table_name"`
	TargetTableOption     string          `json:"target_table_option"`
	OracleCollation       bool            `json:"oracle_collation"`
	SourceSchemaCollation string          `json:"source_schema_collation"` // 可为空
	SourceTableCollation  string          `json:"source_table_collation"`  // 可为空
	SourceDBNLSSort       string          `json:"sourcedb_nlssort"`
	SourceDBNLSComp       string          `json:"sourcedb_nlscomp"`
	SourceTableType       string          `json:"source_table_type"`
	Overwrite             bool            `json:"overwrite"`
	Oracle                *oracle.Oracle  `json:"-"`
	MySQL                 *mysql.MySQL    `json:"-"`
}

func GenReverseTableTask 

func GenReverseTableTask(ctx context.Context, cfg *config.Config, mysql *mysql.MySQL, oracle *oracle.Oracle, exporters []string, nlsSort, nlsComp string) ([]*Table, error)

func (*Table) GenTableSuffix 

func (t *Table) GenTableSuffix(primaryColumns []string, singleIntegerPK bool) (tableSuffix string, err error)

O2M special

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) GetTableNormalIndex 

func (t *Table) GetTableNormalIndex() ([]map[string]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) IsSingleIntegerPK 

func (t *Table) IsSingleIntegerPK(primaryColumns []string, columnMetas []string) bool

判断 Oracle 主键是否是整型主键

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.