o2t

package
v1.0.20 Latest Latest
Warning

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

Go to latest
Published: Jul 26, 2023 License: Apache-2.0 Imports: 18 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.

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.

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.

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 r. 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.

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.Write, sourceSchema string, partitionTables, temporaryTables, clusteredTables []string, materializedViews []string) error

func GenCreateSchema

func GenCreateSchema(w *reverse.Write, lowerCaseFieldName, sourceSchema, targetSchema, sourceDBCharset string, nlsComp string, directWrite bool) error

func IChanger

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

func IWriter

func IWriter(w *reverse.Write, iw reverse.Writer) (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"`
	SourceTableDDL     string   `json:"-"` // 忽略
	TargetSchemaName   string   `json:"target_schema"`
	TargetTableName    string   `json:"target_table_name"`
	TargetDBVersion    string   `json:"target_db_version"`
	TablePrefix        string   `json:"table_prefix"`
	TableColumns       []string `json:"table_columns"`
	TableKeys          []string `json:"table_keys"`
	TableSuffix        string   `json:"table_suffix"`
	TableComment       string   `json:"table_comment"`
	TableCheckKeys     []string `json:"table_check_keys""`
	TableForeignKeys   []string `json:"table_foreign_keys"`
	TableCompatibleDDL []string `json:"table_compatible_ddl"`
}

func IReverse

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

func (*DDL) GenDDLStructure

func (d *DDL) GenDDLStructure() ([]string, []string)

func (*DDL) String

func (d *DDL) String() string

func (*DDL) Write

func (d *DDL) Write(w *reverse.Write) (string, error)

func (*DDL) WriteDB

func (d *DDL) WriteDB(w *reverse.Write) (string, error)

func (*DDL) WriteFile

func (d *DDL) WriteFile(w *reverse.Write) (string, error)

type Info

type Info struct {
	SourceTableDDL    string              `json:"-"` // 忽略
	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"`
}

type Reverse

type Reverse struct {
	Ctx    context.Context
	Cfg    *config.Config
	Mysql  *mysql.MySQL
	Oracle *oracle.Oracle
	MetaDB *meta.Meta
}

func NewReverse

func NewReverse(ctx context.Context, cfg *config.Config) (*Reverse, error)

func (*Reverse) Reverse

func (r *Reverse) Reverse() 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

func (r *Rule) GenSchemaName() string

func (*Rule) GenTableCheckKey

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

func (*Rule) GenTableColumn

func (r *Rule) GenTableColumn() (tableColumns []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

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

func (*Rule) GenTableName

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

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

O2M Special

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:"-"`
	SourceSchemaName      string          `json:"source_schema_name"`
	TargetSchemaName      string          `json:"target_schema_name"`
	SourceTableName       string          `json:"source_table_name"`
	TargetDBVersion       string          `json:"target_db_version"`
	TargetTableName       string          `json:"target_table_name"`
	TargetTableOption     string          `json:"target_table_option"`
	SourceDBCharset       string          `json:"sourcedb_charset"`
	TargetDBCharset       string          `json:"targetdb_charset"`
	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"`
	LowerCaseFieldName    string          `json:"lower_case_field_name"`

	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, oracleDBVersion string, oracleDBCharset, targetDBCharset string, oracleCollation bool, lowerCaseFieldName string, exporters []string, nlsSort, nlsComp 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

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

func (*Table) GetTableNormalIndex

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

func (*Table) GetTableOriginDDL

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL