o2t

package
v1.0.33 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2024 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.

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

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.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]bool, 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"`
	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, error)

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, error)

func (*Rule) GenTableNormalIndex 

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

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"`
	TargetTableNonClustered map[string]string   `json:"target_table_nonclustered"`
	TargetTableClustered    map[string]struct{} `json:"target_table_clustered"`
	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"`
	TableColumnDefaultValSourceRule map[string]bool   `json:"table_column_default_val_source_rule"` // 判断表字段 defaultVal 来源于 database or custom
	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 map[string]map[string]string, tableDefaultSourceRule map[string]map[string]bool, tableDefaultRule map[string]map[string]string, tableClusteredRuleMap map[string]struct{}, tableNonClusteredRuleMap 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

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.