oracle

package
v0.0.0-...-3ee8347 Latest Latest
Warning

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

Go to latest
Published: May 8, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const WriteModeInsert = "insert"

WriteModeInsert represents the insert into write mode.

Variables

This section is empty.

Functions

func NewSource

func NewSource(bs *database.BaseSource) (s database.Source, err error)

NewSource generates an Oracle data source and will report an error if there's an issue with the configuration file

func Quoted

func Quoted(s string) string

Quoted is the quoting function for Oracle

Types

type Config

type Config struct {
	URL      string `json:"url"`      // Database URL, including the database address and other database parameters
	Username string `json:"username"` // Username
	Password string `json:"password"` // Password
}

func NewConfig

func NewConfig(conf *config.JSON) (c *Config, err error)

NewConfig creates an Oracle configuration and will report an error if the format does not meet the requirements

func (*Config) FetchConnectionParams

func (c *Config) FetchConnectionParams() (con godror.ConnectionParams, err error)

FetchConnectionParams retrieves the Oracle connection parameters and will report an error if the URL is incorrect

type Dialect

type Dialect struct{}

Dialect represents the database dialect for Oracle

func (Dialect) Name

func (d Dialect) Name() string

Name is the registered name of the database dialect

func (Dialect) Source

func (d Dialect) Source(bs *database.BaseSource) (database.Source, error)

Source generates an Oracle data source

type Field

type Field struct {
	*database.BaseField
	database.BaseConfigSetter
}

Field Field

func NewField

func NewField(bf *database.BaseField) *Field

NewField Generate a field based on basic column attributes

func (*Field) BindVar

func (f *Field) BindVar(i int) string

BindVar SQL placeholder, used in SQL statements

func (*Field) Quoted

func (f *Field) Quoted() string

Quoted Quotation, used in SQL statements

func (*Field) Scanner

func (f *Field) Scanner() database.Scanner

Scanner Scanner, used for reading data

func (*Field) Select

func (f *Field) Select() string

Select Field for querying, used in SQL query statements

func (*Field) Type

func (f *Field) Type() database.FieldType

Type Field type

func (*Field) Valuer

func (f *Field) Valuer(c element.Column) database.Valuer

Valuer Valuer, using GoValuer to process data

type FieldType

type FieldType struct {
	*database.BaseFieldType
	// contains filtered or unexported fields
}

FieldType Field type

func NewFieldType

func NewFieldType(typ database.ColumnType) *FieldType

NewFieldType Create a new field type

func (*FieldType) IsSupported

func (f *FieldType) IsSupported() bool

IsSupported Whether it supports parsing

type InsertParam

type InsertParam struct {
	*database.BaseParam
}

InsertParam represents the parameters for the insert into operation.

func NewInsertParam

func NewInsertParam(t database.Table, txOpts *sql.TxOptions) *InsertParam

NewInsertParam creates insert parameters based on the table and transaction options (txOpts).

func (*InsertParam) Agrs

func (ip *InsertParam) Agrs(records []element.Record) (valuers []interface{}, err error)

Agrs generates a batch of insert into parameters based on multiple records.

func (*InsertParam) Query

func (ip *InsertParam) Query(_ []element.Record) (query string, err error)

Query generates a batch of insert into SQL statements for insertion based on multiple records.

type Scanner

type Scanner struct {
	database.BaseScanner
	// contains filtered or unexported fields
}

Scanner Scanner

func NewScanner

func NewScanner(f *Field) *Scanner

NewScanner Generate a scanner based on the column type

func (*Scanner) Scan

func (s *Scanner) Scan(src interface{}) (err error)

Scan Read data based on the column type BOOLEAN is treated as a bool type BINARY_INTEGER is treated as a bigint type NUMBER, FLOAT, DOUBLE are treated as decimal types TIMESTAMP, TIMESTAMP WITH TIME ZONE, TIMESTAMP WITH LOCAL TIME ZONE, DATE are treated as time types CLOB, NCLOB, VARCHAR2, NVARCHAR2, CHAR, NCHAR are treated as string types BLOB, RAW, LONG RAW, LONG are treated as byte types

type Source

type Source struct {
	*database.BaseSource // Basic data source
	// contains filtered or unexported fields
}

Source oracle refers to the Oracle data source

func (*Source) ConnectName

func (s *Source) ConnectName() string

ConnectName is the connection information for the Oracle data source using github.com/godror/godror

func (*Source) DriverName

func (s *Source) DriverName() string

DriverName is the driver name for github.com/godror/godror

func (*Source) Key

func (s *Source) Key() string

Key is a keyword for the data source, used for reuse by DBWrapper

func (*Source) Table

func (s *Source) Table(b *database.BaseTable) database.Table

Table generates a table for Oracle

type Table

type Table struct {
	*database.BaseTable
	database.BaseConfigSetter
}

Table represents an Oracle table.

func NewTable

func NewTable(b *database.BaseTable) *Table

NewTable creates a new Oracle table. Note that at this point, the schema parameter in BaseTable is empty, instance is the database name, and name is the table name.

func (*Table) AddField

func (t *Table) AddField(baseField *database.BaseField)

AddField adds a new column to the table.

func (*Table) ExecParam

func (t *Table) ExecParam(mode string, txOpts *sql.TxOptions) (database.Parameter, bool)

ExecParam retrieves execution parameters, where the replace into parameter mode has been registered.

func (*Table) Quoted

func (t *Table) Quoted() string

Quoted refers to the fully qualified name of the table.

func (*Table) ShouldOneByOne

func (t *Table) ShouldOneByOne(err error) bool

ShouldOneByOne specifies whether to retry one operation at a time.

func (*Table) ShouldRetry

func (t *Table) ShouldRetry(err error) bool

ShouldRetry determines whether a retry is necessary.

func (*Table) String

func (t *Table) String() string

type Valuer

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

Valuer Valuer

func NewValuer

func NewValuer(f *Field, c element.Column) *Valuer

NewValuer Create a new valuer

func (*Valuer) Value

func (v *Valuer) Value() (value driver.Value, err error)

Value Assignment

Jump to

Keyboard shortcuts

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