element

package
v0.2.1 Latest Latest
Warning

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

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

README

go-etl Data Type Descriptions

This package primarily defines the data types used in go-etl.

Record

// Record represents a data record.
type Record interface {
 fmt.Stringer

 Add(Column) error                      // Adds a new column.
 GetByIndex(i int) (Column, error)      // Retrieves the column at the specified index.
 GetByName(name string) (Column, error) // Retrieves the column with the specified name.
 Set(i int, c Column) error             // Sets the column at the specified index.
 ColumnNumber() int                     // Returns the number of columns.
 ByteSize() int64                       // Returns the size of the record in bytes.
 MemorySize() int64                     // Returns the memory usage of the record.
}

Data Type Conversions

go-etl supports six internal data types:

  • bigInt: Fixed-point numbers (int64, int32, int16, int8, BigInt, etc.).
  • decimal: Floating-point numbers (float32, float64, BigDecimal (unlimited precision), etc.).
  • string: String type, with unlimited length and using a universal character set (Unicode).
  • time: Date and time type.
  • bool: Boolean value.
  • bytes: Binary data, which can store unstructured data such as MP3 files.

Correspondingly, there are six implementations of ColumnValue: TimeColumnValue, BigIntColumnValue, DecimalColumnValue, BytesColumnValue, StringColumnValue, and BoolColumnValue.

These ColumnValue interfaces provide a series of data type conversion methods that start with as.

// ColumnValue represents a value in a column.
type ColumnValue interface {
 fmt.Stringer

 Type() ColumnType                    // Returns the column type.
 IsNil() bool                         // Checks if the value is nil.
 AsBool() (bool, error)               // Converts the value to a boolean.
 AsBigInt() (*big.Int, error)         // Converts the value to a big integer.
 AsDecimal() (decimal.Decimal, error) // Converts the value to a decimal with unlimited precision.
 AsString() (string, error)           // Converts the value to a string.
 AsBytes() ([]byte, error)            // Converts the value to a byte array.
 AsTime() (time.Time, error)          // Converts the value to a time.
}

Based on the ColumnValue interface, the following methods are implemented:

// Column represents a data column.
type Column interface {
 ColumnValue
 AsInt64() (int64, error)     // Converts the value to a 64-bit integer.
 AsFloat64() (float64, error) // Converts the value to a 64-bit floating point number.
 Clone() (Column, error)      // Clones the column.
 Cmp(Column) (int, error)     // Compares the column with another column. Returns 1 if greater, 0 if equal, -1 if less.
 Name() string                // Returns the name of the column.
 ByteSize() int64             // Returns the size of the column in bytes.
 MemorySize() int64           // Returns the memory usage of the column.
}

The internal types of DataX are implemented using different Golang types: Currently, there are two implementation approaches, but the older approach has performance issues when dealing with large datasets. The new implementation is still in beta and has not been thoroughly validated through practical use.

  • Older Implementation Approach
Internal Type Implementation Type Notes
time time.Time
bigInt big.Int Uses arbitrary-precision integers to ensure no loss of precision.
decimal decimal.Decimal Represented using decimal.Decimal to ensure no loss of precision.
bytes []byte
string string
bool bool
  • Current Implementation Approach
Internal Type Implementation Type Notes
time time.Time
bigInt BigIntNumber Uses a hybrid approach of storing values as Int64 and BigIntStr to ensure no loss of precision.
decimal DecimalNumber Uses a hybrid approach of storing values as Float64, Int64, BigIntStr, DecimalStr, and Decimal to ensure no loss of precision.
bytes []byte
string string
bool bool

The gap between these two implementation methods mainly lies in numerical adjustments, which are integrated through the following interfaces:

// NumberConverter: Digital Converter
type NumberConverter interface {
 ConvertBigIntFromInt(i int64) (num BigIntNumber)
 ConvertDecimalFromFloat(f float64) (num DecimalNumber)
 ConvertBigInt(s string) (num BigIntNumber, err error)
 ConvertDecimal(s string) (num DecimalNumber, err error)
}

// Number: Represents a numeric value
type Number interface {
 Bool() (bool, error)
 String() string
}

// BigIntNumber: Represents a high-precision integer
type BigIntNumber interface {
 Number

 Int64() (int64, error)
 Decimal() DecimalNumber
 CloneBigInt() BigIntNumber
 AsBigInt() *big.Int
}

// DecimalNumber: Represents a high-precision decimal number
type DecimalNumber interface {
 Number

 Float64() (float64, error)
 BigInt() BigIntNumber
 CloneDecimal() DecimalNumber
 AsDecimal() decimal.Decimal
}

The main implementations are Converter (the current implementation method) and OldConverter (the previous implementation method). Converter outperforms OldConverter in terms of performance. The test results from number_bench_test.go are as follows:

BenchmarkConverter_ConvertFromBigInt-4                	34292768	        40.13 ns/op	       8 B/op	       0 allocs/op
BenchmarkOldConverter_ConvertFromBigInt-4             	19314712	        58.69 ns/op	      16 B/op	       1 allocs/op
BenchmarkConverter_ConvertDecimalFromloat-4           	100000000	        15.74 ns/op	       8 B/op	       0 allocs/op
BenchmarkOldConverter_ConvertDecimalFromFloat-4       	 1654504	       725.8 ns/op	      48 B/op	       2 allocs/op
BenchmarkConverter_ConvertBigInt_Int64-4              	 5020077	       230.0 ns/op	      39 B/op	       2 allocs/op
BenchmarkOldConverter_ConvertBigInt_Int64-4           	 2232102	       627.3 ns/op	     111 B/op	       5 allocs/op
BenchmarkCoventor_ConvertBigInt_large_number-4        	   50010	     21211 ns/op	    8064 B/op	     216 allocs/op
BenchmarkOldCoventor_ConvertBigInt_large_number-4     	   23709	     51818 ns/op	    9216 B/op	     360 allocs/op
BenchmarkConverter_ConvertDecimal_Int64-4             	 3830624	       312.6 ns/op	      39 B/op	       2 allocs/op
BenchmarkOldConverter_ConvertDecimal_Int64-4          	 1995441	       611.4 ns/op	     116 B/op	       4 allocs/op
BenchmarkConverter_ConvertDecimal_Float64-4           	 1707649	       671.4 ns/op	     178 B/op	       5 allocs/op
BenchmarkOldConverter_ConvertDecimal_Float64-4        	 1229505	       991.1 ns/op	     191 B/op	       6 allocs/op
BenchmarkConverter_ConvertDecimal-4                   	   80113	     15009 ns/op	    2280 B/op	     144 allocs/op
BenchmarkOldConverter_ConvertDecimal-4                	   56880	     26496 ns/op	    4608 B/op	     288 allocs/op
BenchmarkConverter_ConvertDecimal_large_number-4      	   45754	     22387 ns/op	    5184 B/op	     144 allocs/op
BenchmarkOldConverter_ConvertDecimal_large_number-4   	   16726	     69543 ns/op	   13248 B/op	     432 allocs/op
BenchmarkConverter_ConvertDecimal_Exp-4               	   15516	     86355 ns/op	   18432 B/op	     648 allocs/op
BenchmarkOldConverter_ConvertDecimal_Exp-4            	   17992	     56777 ns/op	   11520 B/op	     432 allocs/op
BenchmarkDecimal_Decmial_String-4                     	 3443062	       361.0 ns/op	      88 B/op	       5 allocs/op
BenchmarkDecimal_DecmialStr_String-4                  	1000000000	         0.6694 ns/op	       0 B/op	       0 allocs/op
BenchmarkDecimal_Float64_String-4                     	 5254669	       260.7 ns/op	      48 B/op	       2 allocs/op
BenchmarkDecimal_Int64_String-4                       	13537401	        89.62 ns/op	      24 B/op	       1 allocs/op
BenchmarkDecimal_BigInt_String-4                      	 4664106	       247.4 ns/op	      56 B/op	       3 allocs/op
BenchmarkDecimal_BigIntStr_String-4                   	1000000000	         0.6873 ns/op	       0 B/op	       0 allocs/op

Additionally, if any issues arise, you can revert to the old implementation by modifying the _DefaultNumberConverter value in number.go.

The relationship between the types and their conversions is as follows:

from\to time bigInt decimal bytes string bool
time - Not supported Not supported Supports conversion of specified time formats (generally supports default time format) Supports conversion of specified time formats (generally supports default time format) Not supported
bigInt Not supported - Supported Supported Supported Converts non-zero values to true, and zero to false
decimal Not supported Rounds to the nearest integer, truncating the decimal part - Supported Supported Converts non-zero values to true, and zero to false
bytes Only supports conversion of specified time formats (generally supports default time format) Real numbers and scientific notation strings are rounded Real numbers and scientific notation strings - Supported Supports conversion of "1", "t", "T", "TRUE", "true", "True" to true, and "0", "f", "F", "FALSE", "false", "False" to false
string Only supports conversion of specified time formats (generally supports default time format) Real numbers and scientific notation strings are rounded Real numbers and scientific notation strings Supported - Supports conversion of "1", "t", "T", "TRUE", "true", "True" to "true", and "0", "f", "F", "FALSE", "false", "False" to false
bool Not supported true converts to 1, false converts to 0 true converts to 1.0, false converts to 0.0 true converts to "true", false converts to "false" true converts to "true", false converts to "false" -

Note: The default time format is 2006-01-02 15:04:05.999999999Z07:00

This table provides an overview of data type conversions between different formats, including time, bigInt, decimal, bytes, string, and bool. It specifies which conversions are supported and which are not, as well as any specific behavior or limitations associated with each conversion.

Documentation

Overview

Package element provides various types of column values, columns, records, and record channels

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrColumnExist              = errors.New("column exist")                  // Column exists error
	ErrColumnNotExist           = errors.New("column does not exist")         // Column does not exist error
	ErrNilValue                 = errors.New("column value is nil")           // Null value error
	ErrIndexOutOfRange          = errors.New("column index is out of range")  // Index value out of range
	ErrValueNotInt64            = errors.New("value is not int64")            // Not an int64 error
	ErrValueInfinity            = errors.New("value is infinity")             // Infinite real number error
	ErrNotColumnValueClonable   = errors.New("columnValue is not clonable")   // Not a clonable column value
	ErrNotColumnValueComparable = errors.New("columnValue is not comparable") // Not a comparable column value
	ErrColumnNameNotEqual       = errors.New("column name is not equal")      // Column names differ
)

Error

View Source 
var DefaultTimeFormat = "2006-01-02 15:04:05.999999999Z07:00"

DefaultTimeFormat - Default time format

Functions

func ByteSize added in v0.1.2 

func ByteSize(src any) int

ByteSize Byte size

Types

type BigInt 

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

BigInt Big integer

func (*BigInt) AsBigInt 

func (b *BigInt) AsBigInt() *big.Int

AsBigInt Convert to high-precision integer

func (*BigInt) AsDecimal 

func (b *BigInt) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*BigInt) BigInt 

func (b *BigInt) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*BigInt) Bool 

func (b *BigInt) Bool() (bool, error)

Bool Convert to boolean

func (*BigInt) CloneBigInt 

func (b *BigInt) CloneBigInt() BigIntNumber

CloneBigInt Clone high-precision integer

func (*BigInt) CloneDecimal 

func (b *BigInt) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*BigInt) Decimal 

func (b *BigInt) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*BigInt) Float64 

func (b *BigInt) Float64() (v float64, err error)

Float64 Convert to 64-bit floating-point number

func (*BigInt) Int64 

func (b *BigInt) Int64() (int64, error)

Int64 Convert to 64-bit integer

func (*BigInt) String 

func (b *BigInt) String() string

Decimal Convert to string

type BigIntColumnValue 

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

BigIntColumnValue - Value for a big integer column

func (*BigIntColumnValue) AsBigInt 

func (b *BigIntColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt - Convert to a big integer

func (*BigIntColumnValue) AsBool 

func (b *BigIntColumnValue) AsBool() (bool, error)

AsBool - Convert to a boolean value, where non-zero becomes true and zero becomes false

func (*BigIntColumnValue) AsBytes 

func (b *BigIntColumnValue) AsBytes() ([]byte, error)

AsBytes - Convert to a byte stream, e.g., 1234556790 becomes [49, 50, 51, 52, 53, 54, 55, 56, 57, 48]

func (*BigIntColumnValue) AsDecimal 

func (b *BigIntColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal - Convert to a high-precision decimal number

func (*BigIntColumnValue) AsString 

func (b *BigIntColumnValue) AsString() (string, error)

AsString - Convert to a string, e.g., 1234556790 becomes 1234556790

func (*BigIntColumnValue) AsTime 

func (b *BigIntColumnValue) AsTime() (time.Time, error)

AsTime - Currently, integers cannot be converted to time

func (*BigIntColumnValue) Clone 

func (b *BigIntColumnValue) Clone() ColumnValue

Clone - Clone the big integer column value

func (*BigIntColumnValue) Cmp 

func (b *BigIntColumnValue) Cmp(right ColumnValue) (int, error)

Cmp - Return 1 for greater than, 0 for equal, and -1 for less than

func (*BigIntColumnValue) IsNil 

func (n *BigIntColumnValue) IsNil() bool

IsNil Whether it is null

func (*BigIntColumnValue) String 

func (b *BigIntColumnValue) String() string

func (*BigIntColumnValue) Type 

func (b *BigIntColumnValue) Type() ColumnType

Type - Return the type of the column

type BigIntNumber 

type BigIntNumber interface {
	Number

	Int64() (int64, error)
	Decimal() DecimalNumber
	CloneBigInt() BigIntNumber
	AsBigInt() *big.Int
}

BigIntNumber High-precision integer

type BigIntStr 

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

BigIntStr High-precision integer string

func (*BigIntStr) AsBigInt 

func (b *BigIntStr) AsBigInt() *big.Int

AsBigInt Convert to high-precision integer

func (*BigIntStr) AsDecimal 

func (b *BigIntStr) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*BigIntStr) BigInt 

func (b *BigIntStr) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*BigIntStr) Bool 

func (b *BigIntStr) Bool() (bool, error)

Bool Convert to boolean

func (*BigIntStr) CloneBigInt 

func (b *BigIntStr) CloneBigInt() BigIntNumber

CloneBigInt Clone high-precision integer

func (*BigIntStr) CloneDecimal 

func (b *BigIntStr) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*BigIntStr) Decimal 

func (b *BigIntStr) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*BigIntStr) Float64 

func (b *BigIntStr) Float64() (v float64, err error)

Float64 Convert to 64-bit floating-point number

func (*BigIntStr) Int64 

func (b *BigIntStr) Int64() (int64, error)

Int64 Convert to 64-bit integer

func (*BigIntStr) String 

func (b *BigIntStr) String() string

Decimal Convert to string

type BoolColumnValue 

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

BoolColumnValue represents a Boolean column value

func (*BoolColumnValue) AsBigInt 

func (b *BoolColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt converts it to a big integer, where true becomes 1 and false becomes 0

func (*BoolColumnValue) AsBool 

func (b *BoolColumnValue) AsBool() (bool, error)

AsBool converts it to a boolean value

func (*BoolColumnValue) AsBytes 

func (b *BoolColumnValue) AsBytes() ([]byte, error)

AsBytes converts it to a byte stream, where true becomes true and false becomes false

func (*BoolColumnValue) AsDecimal 

func (b *BoolColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal converts it to a high-precision decimal number, where true becomes 1.0 and false becomes 0.0

func (*BoolColumnValue) AsString 

func (b *BoolColumnValue) AsString() (string, error)

AsString converts it to a string, where true becomes true and false becomes false

func (*BoolColumnValue) AsTime 

func (b *BoolColumnValue) AsTime() (time.Time, error)

AsTime Currently, a Boolean cannot be converted to a time value

func (*BoolColumnValue) Clone 

func (b *BoolColumnValue) Clone() ColumnValue

Clone clones a Boolean column value

func (*BoolColumnValue) Cmp 

func (b *BoolColumnValue) Cmp(right ColumnValue) (int, error)

Cmp Returns 1 for greater than, 0 for equal, and -1 for less than

func (*BoolColumnValue) IsNil 

func (n *BoolColumnValue) IsNil() bool

IsNil Whether it is null

func (*BoolColumnValue) String 

func (b *BoolColumnValue) String() string

func (*BoolColumnValue) Type 

func (b *BoolColumnValue) Type() ColumnType

Type returns the type of the column

type BytesColumnValue 

type BytesColumnValue struct {
	TimeEncoder // Time Encoder
	// contains filtered or unexported fields
}

BytesColumnValue - Byte stream column value

func (*BytesColumnValue) AsBigInt 

func (b *BytesColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt - Convert to an integer. Real numbers and scientific notation strings will be rounded. Non-numeric values will report an error. E.g., 123.67 is converted to 123, and 123.12 is converted to 123.

func (*BytesColumnValue) AsBool 

func (b *BytesColumnValue) AsBool() (bool, error)

AsBool - Convert 1, t, T, TRUE, true, True to true Convert 0, f, F, FALSE, false, False to false. If none of the above, an error is reported.

func (*BytesColumnValue) AsBytes 

func (b *BytesColumnValue) AsBytes() ([]byte, error)

AsBytes - Convert to a byte stream

func (*BytesColumnValue) AsDecimal 

func (b *BytesColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal - Convert to a high-precision decimal. Real numbers and scientific notation strings can be converted. Non-numeric values will report an error.

func (*BytesColumnValue) AsString 

func (b *BytesColumnValue) AsString() (string, error)

AsString - Convert to a string

func (*BytesColumnValue) AsTime 

func (b *BytesColumnValue) AsTime() (t time.Time, err error)

AsTime - Convert to time based on the time encoder. If it does not match the time encoder format, an error is reported.

func (*BytesColumnValue) Clone 

func (b *BytesColumnValue) Clone() ColumnValue

Clone - Clone the byte stream column value

func (*BytesColumnValue) Cmp 

func (b *BytesColumnValue) Cmp(right ColumnValue) (int, error)

Cmp - Return 1 for greater than, 0 for equal, and -1 for less than

func (*BytesColumnValue) IsNil 

func (n *BytesColumnValue) IsNil() bool

IsNil Whether it is null

func (*BytesColumnValue) String 

func (b *BytesColumnValue) String() string

func (*BytesColumnValue) Type 

func (b *BytesColumnValue) Type() ColumnType

Type - Return the column type

type Column 

type Column interface {
	ColumnValue
	AsInt64() (int64, error)     // ToInt64: Convert to 64-bit integer
	AsFloat64() (float64, error) // ToFloat64: Convert to 64-bit real number
	Clone() (Column, error)      // Clone: Clone
	Cmp(Column) (int, error)     // Compare: 1 represents greater than, 0 represents equal, -1 represents less than
	Name() string                // Name: Column name
	ByteSize() int64             // ByteSize: Byte stream size
	MemorySize() int64           // MemorySize: Memory size
}

Column Column

func NewDefaultColumn 

func NewDefaultColumn(v ColumnValue, name string, byteSize int) Column

NewDefaultColumn Create a new default column based on column value v, column name name, and byte stream size byteSize

type ColumnType 

type ColumnType string

ColumnType Column Type 

const (
	TypeUnknown ColumnType = "unknown" // UnknownType: Unknown type
	TypeBool    ColumnType = "bool"    // BoolType: Boolean type
	TypeBigInt  ColumnType = "bigInt"  // IntType: Integer type
	TypeDecimal ColumnType = "decimal" // DecimalType: High-precision real number type
	TypeString  ColumnType = "string"  // StringType: String type
	TypeBytes   ColumnType = "bytes"   // BytesType: Byte stream type
	TypeTime    ColumnType = "time"    // TimeType: Time type
)

ColumnTypeEnum Enumeration of column types

func (ColumnType) String 

func (c ColumnType) String() string

String Printing display

type ColumnValue 

type ColumnValue interface {
	fmt.Stringer

	Type() ColumnType                  // ColumnType: Column type
	IsNil() bool                       // IsNull: Whether it is null
	AsBool() (bool, error)             // ToBool: Convert to boolean
	AsBigInt() (BigIntNumber, error)   // ToInt: Convert to integer
	AsDecimal() (DecimalNumber, error) // ToDecimal: Convert to high-precision real number
	AsString() (string, error)         // ToString: Convert to string
	AsBytes() ([]byte, error)          // ToBytes: Convert to byte stream
	AsTime() (time.Time, error)        // ToTime: Convert to time
}

ColumnValue Column Value

func NewBigIntColumnValue 

func NewBigIntColumnValue(v *big.Int) ColumnValue

NewBigIntColumnValue - Create a big integer column value from a big.Int v

func NewBigIntColumnValueFromInt64 

func NewBigIntColumnValueFromInt64(v int64) ColumnValue

NewBigIntColumnValueFromInt64 - Create a big integer column value from an int64 v

func NewBigIntColumnValueFromString 

func NewBigIntColumnValueFromString(v string) (ColumnValue, error)

NewBigIntColumnValueFromString - Create a big integer column value from a string v If the string v is not an integer, an error is returned

func NewBigIntColumnValueFromUint64 added in v0.2.0 

func NewBigIntColumnValueFromUint64(v uint64) ColumnValue

NewBigIntColumnValueFromUint64 - Create a big integer column value from an int64 v

func NewBoolColumnValue 

func NewBoolColumnValue(v bool) ColumnValue

NewBoolColumnValue creates a Boolean column value from the boolean value v

func NewBytesColumnValue 

func NewBytesColumnValue(v []byte) ColumnValue

NewBytesColumnValue - Generate a byte stream column value from byte stream v, making a copy

func NewBytesColumnValueNoCopy 

func NewBytesColumnValueNoCopy(v []byte) ColumnValue

NewBytesColumnValueNoCopy - Generate a byte stream column value from byte stream v, without making a copy

func NewBytesColumnValueWithEncoder 

func NewBytesColumnValueWithEncoder(v []byte, e TimeEncoder) ColumnValue

NewBytesColumnValueWithEncoder - Generate a byte stream column value from byte stream v and time encoder e, making a copy

func NewBytesColumnValueWithEncoderNoCopy 

func NewBytesColumnValueWithEncoderNoCopy(v []byte, e TimeEncoder) ColumnValue

NewBytesColumnValueWithEncoderNoCopy - Generate a byte stream column value from byte stream v and time encoder e, without making a copy

func NewDecimalColumnValue 

func NewDecimalColumnValue(d decimal.Decimal) ColumnValue

NewDecimalColumnValue creates a high-precision decimal column value from a high-precision decimal value.

func NewDecimalColumnValueFromFloat 

func NewDecimalColumnValueFromFloat(f float64) ColumnValue

NewDecimalColumnValueFromFloat creates a high-precision decimal column value from a float64 value.

func NewDecimalColumnValueFromFloat32 added in v0.2.0 

func NewDecimalColumnValueFromFloat32(f float32) ColumnValue

NewDecimalColumnValueFromFloat32 creates a high-precision decimal column value from a float64 value.

func NewDecimalColumnValueFromString 

func NewDecimalColumnValueFromString(s string) (ColumnValue, error)

NewDecimalColumnValueFromString creates a high-precision decimal column value from a string. If the string is not a numeric value or in scientific notation, an error will be reported.

func NewNilBigIntColumnValue 

func NewNilBigIntColumnValue() ColumnValue

NewNilBigIntColumnValue - Create a null value for a big integer column

func NewNilBoolColumnValue 

func NewNilBoolColumnValue() ColumnValue

NewNilBoolColumnValue creates an empty Boolean column value

func NewNilBytesColumnValue 

func NewNilBytesColumnValue() ColumnValue

NewNilBytesColumnValue - Create a null byte stream column value

func NewNilDecimalColumnValue 

func NewNilDecimalColumnValue() ColumnValue

NewNilDecimalColumnValue creates a null value for a high-precision decimal column.

func NewNilStringColumnValue 

func NewNilStringColumnValue() ColumnValue

NewNilStringColumnValue - Create a null value for a string column

func NewNilTimeColumnValue 

func NewNilTimeColumnValue() ColumnValue

NewNilTimeColumnValue creates an empty time column value

func NewStringColumnValue 

func NewStringColumnValue(s string) ColumnValue

NewStringColumnValue - Create a string column value based on the string s

func NewStringColumnValueWithEncoder 

func NewStringColumnValueWithEncoder(s string, e TimeEncoder) ColumnValue

NewStringColumnValueWithEncoder - Create a string column value based on the string s and time encoder e

func NewTimeColumnValue 

func NewTimeColumnValue(t time.Time) ColumnValue

NewTimeColumnValue creates a time column value from the time t

func NewTimeColumnValueWithDecoder 

func NewTimeColumnValueWithDecoder(t time.Time, d TimeDecoder) ColumnValue

NewTimeColumnValueWithDecoder creates a time column value from the time t and the time decoder

type ColumnValueClonable 

type ColumnValueClonable interface {
	Clone() ColumnValue // Clone: Clone
}

ColumnValueClonable Cloneable column value

type ColumnValueComparabale 

type ColumnValueComparabale interface {
	// Compare: 1 represents greater than, 0 represents equal, -1 represents less than
	Cmp(ColumnValue) (int, error)
}

ColumnValueComparabale Comparable column value

type Converter 

type Converter struct{}

Converter Number converter

func (*Converter) ConvertBigInt 

func (c *Converter) ConvertBigInt(s string) (num BigIntNumber, err error)

ConvertBigInt converts a string to an integer

func (*Converter) ConvertBigIntFromInt 

func (c *Converter) ConvertBigIntFromInt(i int64) (num BigIntNumber)

ConvertBigIntFromInt Convert to decimal from integer

func (*Converter) ConvertBigIntFromUint added in v0.2.0 

func (c *Converter) ConvertBigIntFromUint(i uint64) (num BigIntNumber)

ConvertBigIntFromUint Convert to decimal from unsigned integer

func (*Converter) ConvertDecimal 

func (c *Converter) ConvertDecimal(s string) (num DecimalNumber, err error)

ConvertDecimal Convert string to decimal

func (*Converter) ConvertDecimalFromFloat 

func (c *Converter) ConvertDecimalFromFloat(f float64) (num DecimalNumber)

ConvertDecimalFromFloat Convert to decimal from floating-point number

func (*Converter) ConvertDecimalFromFloat32 added in v0.2.0 

func (c *Converter) ConvertDecimalFromFloat32(f float32) (num DecimalNumber)

ConvertDecimalFromFloat32 Convert to decimal from 32-bit loating-point number

type Decimal 

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

Decimal High-precision decimal

func (*Decimal) AsDecimal 

func (d *Decimal) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*Decimal) BigInt 

func (d *Decimal) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*Decimal) Bool 

func (d *Decimal) Bool() (bool, error)

Bool Convert to boolean

func (*Decimal) CloneDecimal 

func (d *Decimal) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*Decimal) Decimal 

func (d *Decimal) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*Decimal) Float64 

func (d *Decimal) Float64() (float64, error)

Float64 Convert to 64-bit floating-point number

func (*Decimal) String 

func (d *Decimal) String() string

Decimal Convert to string

type DecimalColumnValue 

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

DecimalColumnValue represents a high-precision decimal column value.

func (*DecimalColumnValue) AsBigInt 

func (d *DecimalColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt rounds down the high-precision decimal value, e.g., 123.67 becomes 123, and 123.12 becomes 123.

func (*DecimalColumnValue) AsBool 

func (d *DecimalColumnValue) AsBool() (bool, error)

AsBool converts non-zero values to true and zero values to false.

func (*DecimalColumnValue) AsBytes 

func (d *DecimalColumnValue) AsBytes() ([]byte, error)

AsBytes converts to a byte stream, e.g., 10.123 becomes the byte representation of 10.123.

func (*DecimalColumnValue) AsDecimal 

func (d *DecimalColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal converts to a high-precision decimal.

func (*DecimalColumnValue) AsString 

func (d *DecimalColumnValue) AsString() (string, error)

AsString converts to a string, e.g., 10.123 becomes 10.123.

func (*DecimalColumnValue) AsTime 

func (d *DecimalColumnValue) AsTime() (time.Time, error)

AsTime currently cannot convert to a time value.

func (*DecimalColumnValue) Clone 

func (d *DecimalColumnValue) Clone() ColumnValue

Clone creates a copy (clone) of a high-precision decimal column value.

func (*DecimalColumnValue) Cmp 

func (d *DecimalColumnValue) Cmp(right ColumnValue) (int, error)

Cmp returns 1 for greater than, 0 for equal, and -1 for less than.

func (*DecimalColumnValue) IsNil 

func (n *DecimalColumnValue) IsNil() bool

IsNil Whether it is null

func (*DecimalColumnValue) String 

func (d *DecimalColumnValue) String() string

func (*DecimalColumnValue) Type 

func (d *DecimalColumnValue) Type() ColumnType

Type represents the type of the column.

type DecimalNumber 

type DecimalNumber interface {
	Number

	Float64() (float64, error)
	BigInt() BigIntNumber
	CloneDecimal() DecimalNumber
	AsDecimal() decimal.Decimal
}

DecimalNumber High-precision decimal

type DecimalStr 

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

DecimalStr High-precision decimal string

func (*DecimalStr) AsDecimal 

func (d *DecimalStr) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*DecimalStr) BigInt 

func (d *DecimalStr) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*DecimalStr) Bool 

func (d *DecimalStr) Bool() (bool, error)

Bool Convert to boolean

func (*DecimalStr) CloneDecimal 

func (d *DecimalStr) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*DecimalStr) Decimal 

func (d *DecimalStr) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*DecimalStr) Float64 

func (d *DecimalStr) Float64() (v float64, err error)

Float64 Convert to 64-bit floating-point number

func (*DecimalStr) String 

func (d *DecimalStr) String() string

Decimal Convert to string

type DefaultColumn 

type DefaultColumn struct {
	ColumnValue // ColumnValue Column value
	// contains filtered or unexported fields
}

DefaultColumn Default value

func (*DefaultColumn) AsFloat64 

func (d *DefaultColumn) AsFloat64() (float64, error)

AsFloat64 Convert to 64-bit real number

func (*DefaultColumn) AsInt64 

func (d *DefaultColumn) AsInt64() (int64, error)

AsInt64 Convert to 64-bit integer

func (*DefaultColumn) ByteSize 

func (d *DefaultColumn) ByteSize() int64

ByteSize Byte stream size

func (*DefaultColumn) Clone 

func (d *DefaultColumn) Clone() (Column, error)

Clone Clone a column. If it's not a cloneable column value, an error will occur.

func (*DefaultColumn) Cmp 

func (d *DefaultColumn) Cmp(c Column) (int, error)

Cmp Compare columns. If it's not a comparable column value, an error will occur.

func (*DefaultColumn) MemorySize 

func (d *DefaultColumn) MemorySize() int64

MemorySize Memory size

func (*DefaultColumn) Name 

func (d *DefaultColumn) Name() string

Name Column name

type DefaultRecord 

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

DefaultRecord represents a default record.

func NewDefaultRecord 

func NewDefaultRecord() *DefaultRecord

NewDefaultRecord creates a new default record.

func (*DefaultRecord) Add 

func (r *DefaultRecord) Add(c Column) error

Add adds a new column c. If column c already exists, an error is reported.

func (*DefaultRecord) ByteSize 

func (r *DefaultRecord) ByteSize() int64

ByteSize represents the size of the record in bytes.

func (*DefaultRecord) ColumnNumber 

func (r *DefaultRecord) ColumnNumber() int

ColumnNumber represents the number of columns in the record.

func (*DefaultRecord) GetByIndex 

func (r *DefaultRecord) GetByIndex(i int) (Column, error)

GetByIndex gets the column at index i. If the index is out of range or doesn't exist, an error is reported.

func (*DefaultRecord) GetByName 

func (r *DefaultRecord) GetByName(name string) (Column, error)

GetByName gets the column with the specified name. If the column doesn't exist, an error is reported.

func (*DefaultRecord) MemorySize 

func (r *DefaultRecord) MemorySize() int64

MemorySize represents the size of the record in memory.

func (*DefaultRecord) Put 

func (r *DefaultRecord) Put(c Column) error

Put sets the value of the column with the specified name. If the column name doesn't exist, an error is reported.

func (*DefaultRecord) Set 

func (r *DefaultRecord) Set(i int, c Column) error

Set sets the value of the column at index i. If the index is out of range, an error is reported.

func (*DefaultRecord) String 

func (r *DefaultRecord) String() string

String is an empty method placeholder.

type Int64 

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

Int64 64-bit integer

func (*Int64) AsBigInt 

func (i *Int64) AsBigInt() *big.Int

AsBigInt Convert to high-precision integer

func (*Int64) AsDecimal 

func (i *Int64) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*Int64) BigInt 

func (i *Int64) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*Int64) Bool 

func (i *Int64) Bool() (bool, error)

Bool Convert to boolean

func (*Int64) CloneBigInt 

func (i *Int64) CloneBigInt() BigIntNumber

CloneBigInt Clone high-precision integer

func (*Int64) CloneDecimal 

func (i *Int64) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*Int64) Decimal 

func (i *Int64) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*Int64) Float64 

func (i *Int64) Float64() (float64, error)

Float64 Convert to 64-bit floating-point number. But it will result in loss of precision.

func (*Int64) Int64 

func (i *Int64) Int64() (int64, error)

Int64 Convert to 64-bit integer

func (*Int64) String 

func (i *Int64) String() string

Decimal Convert to string

type NilBigIntColumnValue 

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

NilBigIntColumnValue - Null value for a big integer column

func (NilBigIntColumnValue) AsBigInt 

func (n NilBigIntColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilBigIntColumnValue) AsBool 

func (n NilBigIntColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilBigIntColumnValue) AsBytes 

func (n NilBigIntColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilBigIntColumnValue) AsDecimal 

func (n NilBigIntColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilBigIntColumnValue) AsString 

func (n NilBigIntColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilBigIntColumnValue) AsTime 

func (n NilBigIntColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilBigIntColumnValue) Clone 

func (n *NilBigIntColumnValue) Clone() ColumnValue

Clone - Clone the null value for a big integer column

func (NilBigIntColumnValue) IsNil 

func (n NilBigIntColumnValue) IsNil() bool

IsNil Whether it is null

func (NilBigIntColumnValue) String 

func (n NilBigIntColumnValue) String() string

String Printing display

func (*NilBigIntColumnValue) Type 

func (n *NilBigIntColumnValue) Type() ColumnType

Type - Return the type of the column

type NilBoolColumnValue 

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

NilBoolColumnValue represents an empty Boolean column value

func (NilBoolColumnValue) AsBigInt 

func (n NilBoolColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilBoolColumnValue) AsBool 

func (n NilBoolColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilBoolColumnValue) AsBytes 

func (n NilBoolColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilBoolColumnValue) AsDecimal 

func (n NilBoolColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilBoolColumnValue) AsString 

func (n NilBoolColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilBoolColumnValue) AsTime 

func (n NilBoolColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilBoolColumnValue) Clone 

func (n *NilBoolColumnValue) Clone() ColumnValue

Clone clones an empty Boolean column value

func (NilBoolColumnValue) IsNil 

func (n NilBoolColumnValue) IsNil() bool

IsNil Whether it is null

func (NilBoolColumnValue) String 

func (n NilBoolColumnValue) String() string

String Printing display

func (*NilBoolColumnValue) Type 

func (n *NilBoolColumnValue) Type() ColumnType

Type returns the type of the column

type NilBytesColumnValue 

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

NilBytesColumnValue - Null byte stream column value

func (NilBytesColumnValue) AsBigInt 

func (n NilBytesColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilBytesColumnValue) AsBool 

func (n NilBytesColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilBytesColumnValue) AsBytes 

func (n NilBytesColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilBytesColumnValue) AsDecimal 

func (n NilBytesColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilBytesColumnValue) AsString 

func (n NilBytesColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilBytesColumnValue) AsTime 

func (n NilBytesColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilBytesColumnValue) Clone 

func (n *NilBytesColumnValue) Clone() ColumnValue

Clone - Clone the null byte stream column value

func (NilBytesColumnValue) IsNil 

func (n NilBytesColumnValue) IsNil() bool

IsNil Whether it is null

func (NilBytesColumnValue) String 

func (n NilBytesColumnValue) String() string

String Printing display

func (*NilBytesColumnValue) Type 

func (n *NilBytesColumnValue) Type() ColumnType

Type - Return the column type

type NilDecimalColumnValue 

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

NilDecimalColumnValue represents a null value for a high-precision decimal column.

func (NilDecimalColumnValue) AsBigInt 

func (n NilDecimalColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilDecimalColumnValue) AsBool 

func (n NilDecimalColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilDecimalColumnValue) AsBytes 

func (n NilDecimalColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilDecimalColumnValue) AsDecimal 

func (n NilDecimalColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilDecimalColumnValue) AsString 

func (n NilDecimalColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilDecimalColumnValue) AsTime 

func (n NilDecimalColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilDecimalColumnValue) Clone 

func (n *NilDecimalColumnValue) Clone() ColumnValue

Clone creates a copy (clone) of a high-precision decimal column value.

func (NilDecimalColumnValue) IsNil 

func (n NilDecimalColumnValue) IsNil() bool

IsNil Whether it is null

func (NilDecimalColumnValue) String 

func (n NilDecimalColumnValue) String() string

String Printing display

func (*NilDecimalColumnValue) Type 

func (n *NilDecimalColumnValue) Type() ColumnType

Type represents the type of the column.

type NilStringColumnValue 

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

NilStringColumnValue - Null value for a string column

func (NilStringColumnValue) AsBigInt 

func (n NilStringColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilStringColumnValue) AsBool 

func (n NilStringColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilStringColumnValue) AsBytes 

func (n NilStringColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilStringColumnValue) AsDecimal 

func (n NilStringColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilStringColumnValue) AsString 

func (n NilStringColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilStringColumnValue) AsTime 

func (n NilStringColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilStringColumnValue) Clone 

func (n *NilStringColumnValue) Clone() ColumnValue

Clone - Clone the null string value

func (NilStringColumnValue) IsNil 

func (n NilStringColumnValue) IsNil() bool

IsNil Whether it is null

func (NilStringColumnValue) String 

func (n NilStringColumnValue) String() string

String Printing display

func (*NilStringColumnValue) Type 

func (n *NilStringColumnValue) Type() ColumnType

Type - Column type

type NilTimeColumnValue 

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

NilTimeColumnValue represents an empty time column value

func (NilTimeColumnValue) AsBigInt 

func (n NilTimeColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Failed to convert to integer

func (NilTimeColumnValue) AsBool 

func (n NilTimeColumnValue) AsBool() (bool, error)

AsBool Failed to convert to boolean

func (NilTimeColumnValue) AsBytes 

func (n NilTimeColumnValue) AsBytes() ([]byte, error)

AsBytes Failed to convert to byte stream

func (NilTimeColumnValue) AsDecimal 

func (n NilTimeColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Failed to convert to high-precision real number

func (NilTimeColumnValue) AsString 

func (n NilTimeColumnValue) AsString() (string, error)

AsString Failed to convert to string

func (NilTimeColumnValue) AsTime 

func (n NilTimeColumnValue) AsTime() (time.Time, error)

AsTime Failed to convert to time

func (*NilTimeColumnValue) Clone 

func (n *NilTimeColumnValue) Clone() ColumnValue

Clone clones an empty time column value

func (NilTimeColumnValue) IsNil 

func (n NilTimeColumnValue) IsNil() bool

IsNil Whether it is null

func (NilTimeColumnValue) String 

func (n NilTimeColumnValue) String() string

String Printing display

func (*NilTimeColumnValue) Type 

func (n *NilTimeColumnValue) Type() ColumnType

Type returns the type of the column

type Number 

type Number interface {
	Bool() (bool, error)
	String() string
}

Number Numeric value

type NumberConverter 

type NumberConverter interface {
	ConvertBigIntFromInt(i int64) (num BigIntNumber)
	ConvertBigIntFromUint(i uint64) (num BigIntNumber)
	ConvertDecimalFromFloat32(f float32) (num DecimalNumber)
	ConvertDecimalFromFloat(f float64) (num DecimalNumber)
	ConvertBigInt(s string) (num BigIntNumber, err error)
	ConvertDecimal(s string) (num DecimalNumber, err error)
}

NumberConverter Number converter

type OldConverter 

type OldConverter struct{}

OldConverter Unchecked conversion

func (*OldConverter) ConvertBigInt 

func (c *OldConverter) ConvertBigInt(s string) (num BigIntNumber, err error)

ConvertBigInt Convert string to integer

func (*OldConverter) ConvertBigIntFromInt 

func (c *OldConverter) ConvertBigIntFromInt(i int64) (num BigIntNumber)

ConvertBigIntFromInt Convert to decimal from integer

func (*OldConverter) ConvertBigIntFromUint added in v0.2.0 

func (c *OldConverter) ConvertBigIntFromUint(i uint64) (num BigIntNumber)

ConvertBigIntFromUint Convert to decimal from unsigned integer

func (*OldConverter) ConvertDecimal 

func (c *OldConverter) ConvertDecimal(s string) (num DecimalNumber, err error)

ConvertDecimal Convert string to decimal

func (*OldConverter) ConvertDecimalFromFloat 

func (c *OldConverter) ConvertDecimalFromFloat(f float64) (num DecimalNumber)

ConvertDecimalFromFloat Convert to decimal from floating-point number

func (*OldConverter) ConvertDecimalFromFloat32 added in v0.2.0 

func (c *OldConverter) ConvertDecimalFromFloat32(f float32) (num DecimalNumber)

ConvertDecimalFromFloat32 Convert to decimal from 32-bit loating-point number

type Record 

type Record interface {
	fmt.Stringer

	Add(Column) error                      // AddColumn adds a new column to the record.
	GetByIndex(i int) (Column, error)      // GetColumnByIndex gets the column at index i.
	GetByName(name string) (Column, error) // GetColumnByName gets the column with the specified name.
	Set(i int, c Column) error             // SetColumnByIndex sets the value of the column at index i.
	Put(c Column) error                    // SetColumn sets the value of the specified column.
	ColumnNumber() int                     // GetColumnCount returns the number of columns in the record.
	ByteSize() int64                       // ByteSize returns the size of the record in bytes.
	MemorySize() int64                     // MemorySize returns the size of the record in memory.
}

Record represents a record in a dataset.

func GetTerminateRecord 

func GetTerminateRecord() Record

GetTerminateRecord gets the termination record.

type RecordChan 

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

RecordChan Record channel. Fixes memory overflow issues.

func NewRecordChan 

func NewRecordChan(ctx context.Context) *RecordChan

NewRecordChan Create a new record channel.

func NewRecordChanBuffer 

func NewRecordChanBuffer(ctx context.Context, n int) *RecordChan

NewRecordChanBuffer Create a new record channel with a capacity of n.

func (*RecordChan) Buffered 

func (c *RecordChan) Buffered() int

Buffered Number of elements currently buffered in the record channel.

func (*RecordChan) Close 

func (c *RecordChan) Close()

Close Close the channel.

func (*RecordChan) PopFront 

func (c *RecordChan) PopFront() (r Record, ok bool)

PopFront Remove and return the record at the front of the channel, and indicate whether there are more values remaining.

func (*RecordChan) PopFrontAll 

func (c *RecordChan) PopFrontAll(onRecord func(Record) error) error

PopFrontAll Remove and return all records from the front of the channel using the onRecord function.

func (*RecordChan) PushBack 

func (c *RecordChan) PushBack(r Record) int

PushBack Append a record r to the end of the channel and return the current size of the queue.

func (*RecordChan) PushBackAll 

func (c *RecordChan) PushBackAll(fetchRecord func() (Record, error)) error

PushBackAll Append multiple records obtained through the fetchRecord function to the end of the channel.

type SetError 

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

SetError Sets an error

func NewSetError 

func NewSetError(i any, other ColumnType, err error) *SetError

NewSetError Generates a setting error by setting the value i to the specified other type with the error err

func (*SetError) Error 

func (e *SetError) Error() string

func (*SetError) Unwrap 

func (e *SetError) Unwrap() error

type StringColumnValue 

type StringColumnValue struct {
	TimeEncoder
	// contains filtered or unexported fields
}

StringColumnValue - Value for a string column. Note: Decimal 123.0 (val:1230, exp:-1) is not equivalent to 123 (val:123, exp:0)

func (*StringColumnValue) AsBigInt 

func (s *StringColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt - Convert to a big integer. Floating-point numbers and scientific notation strings will be rounded. Non-numeric values will throw an error. E.g., 123.67 is converted to 123, and 123.12 is converted to 123.

func (*StringColumnValue) AsBool 

func (s *StringColumnValue) AsBool() (v bool, err error)

AsBool - Convert 1, t, T, TRUE, true, True to true Convert 0, f, F, FALSE, false, False to false. If none of the above, an error is thrown.

func (*StringColumnValue) AsBytes 

func (s *StringColumnValue) AsBytes() ([]byte, error)

AsBytes - Convert to a byte stream

func (*StringColumnValue) AsDecimal 

func (s *StringColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal - Convert to a decimal. Floating-point numbers and scientific notation strings can be converted. Non-numeric values will throw an error.

func (*StringColumnValue) AsString 

func (s *StringColumnValue) AsString() (string, error)

AsString - Convert to a string

func (*StringColumnValue) AsTime 

func (s *StringColumnValue) AsTime() (t time.Time, err error)

AsTime - Convert to a time based on the time encoder. If the format does not match the time encoder, an error is thrown.

func (*StringColumnValue) Clone 

func (s *StringColumnValue) Clone() ColumnValue

Clone - Clone the string column value

func (*StringColumnValue) Cmp 

func (s *StringColumnValue) Cmp(right ColumnValue) (int, error)

Cmp - Return 1 for greater than, 0 for equal, -1 for less than

func (*StringColumnValue) IsNil 

func (n *StringColumnValue) IsNil() bool

IsNil Whether it is null

func (*StringColumnValue) String 

func (s *StringColumnValue) String() string

func (*StringColumnValue) Type 

func (s *StringColumnValue) Type() ColumnType

Type - Column type

type StringTimeDecoder 

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

StringTimeDecoder - String time decoder

func (*StringTimeDecoder) Layout added in v0.1.1 

func (d *StringTimeDecoder) Layout() string

Layout - Time format

func (*StringTimeDecoder) TimeDecode 

func (d *StringTimeDecoder) TimeDecode(t time.Time) (any, error)

TimeDecode - Decode a string time based on the layout of the go time format into a string

type StringTimeEncoder 

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

StringTimeEncoder - String time encoder

func (*StringTimeEncoder) TimeEncode 

func (e *StringTimeEncoder) TimeEncode(i any) (time.Time, error)

TimeEncode - Encode to time. If 'i' is not a string or not in the layout format, an error will be reported.

type TerminateRecord 

type TerminateRecord struct{}

TerminateRecord represents a termination record.

func (*TerminateRecord) Add 

func (t *TerminateRecord) Add(Column) error

Add is an empty method placeholder.

func (*TerminateRecord) ByteSize 

func (t *TerminateRecord) ByteSize() int64

ByteSize is an empty method placeholder.

func (*TerminateRecord) ColumnNumber 

func (t *TerminateRecord) ColumnNumber() int

ColumnNumber is an empty method placeholder.

func (*TerminateRecord) GetByIndex 

func (t *TerminateRecord) GetByIndex(i int) (Column, error)

GetByIndex is an empty method placeholder.

func (*TerminateRecord) GetByName 

func (t *TerminateRecord) GetByName(name string) (Column, error)

GetByName is an empty method placeholder.

func (*TerminateRecord) MemorySize 

func (t *TerminateRecord) MemorySize() int64

MemorySize is an empty method placeholder.

func (*TerminateRecord) Put 

func (t *TerminateRecord) Put(c Column) error

Put is an empty method placeholder.

func (*TerminateRecord) Set 

func (t *TerminateRecord) Set(i int, c Column) error

Set is an empty method placeholder.

func (*TerminateRecord) String 

func (t *TerminateRecord) String() string

String is an empty method placeholder.

type TimeColumnValue 

type TimeColumnValue struct {
	TimeDecoder // Time decoder
	// contains filtered or unexported fields
}

TimeColumnValue represents a time column value

func (*TimeColumnValue) AsBigInt 

func (t *TimeColumnValue) AsBigInt() (BigIntNumber, error)

AsBigInt Cannot convert to a big integer

func (*TimeColumnValue) AsBool 

func (t *TimeColumnValue) AsBool() (bool, error)

AsBool Cannot convert to a boolean value

func (*TimeColumnValue) AsBytes 

func (t *TimeColumnValue) AsBytes() (b []byte, err error)

AsBytes Converts to a byte stream

func (*TimeColumnValue) AsDecimal 

func (t *TimeColumnValue) AsDecimal() (DecimalNumber, error)

AsDecimal Cannot convert to a high-precision decimal number

func (*TimeColumnValue) AsString 

func (t *TimeColumnValue) AsString() (s string, err error)

AsString Converts to a string

func (*TimeColumnValue) AsTime 

func (t *TimeColumnValue) AsTime() (time.Time, error)

AsTime Converts to a time value

func (*TimeColumnValue) Clone 

func (t *TimeColumnValue) Clone() ColumnValue

Clone clones a time column value

func (*TimeColumnValue) Cmp 

func (t *TimeColumnValue) Cmp(right ColumnValue) (int, error)

Cmp Returns 1 for greater than, 0 for equal, and -1 for less than

func (*TimeColumnValue) IsNil 

func (n *TimeColumnValue) IsNil() bool

IsNil Whether it is null

func (*TimeColumnValue) String 

func (t *TimeColumnValue) String() string

func (*TimeColumnValue) Type 

func (t *TimeColumnValue) Type() ColumnType

Type returns the type of the column

type TimeDecoder 

type TimeDecoder interface {
	TimeDecode(t time.Time) (any, error)
	Layout() string
}

TimeDecoder - Time decoder

func NewStringTimeDecoder 

func NewStringTimeDecoder(layout string) TimeDecoder

NewStringTimeDecoder - A string time decoder based on the layout of the go time format

type TimeEncoder 

type TimeEncoder interface {
	TimeEncode(i any) (time.Time, error)
}

TimeEncoder - Time encoder

func NewStringTimeEncoder 

func NewStringTimeEncoder(layout string) TimeEncoder

NewStringTimeEncoder - A string time encoder based on the layout of the go time format

type TransformError 

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

TransformError Conversion error

func NewTransformError 

func NewTransformError(msg string, err error) *TransformError

NewTransformError Creates a conversion error based on the message msg and error err

func NewTransformErrorFormColumnTypes 

func NewTransformErrorFormColumnTypes(one, other ColumnType, err error) *TransformError

NewTransformErrorFormColumnTypes Generates a conversion error from the error err when converting from type one to type other

func NewTransformErrorFormString 

func NewTransformErrorFormString(one, other string, err error) *TransformError

NewTransformErrorFormString Generates a conversion error from the error err when converting from one to other

func (*TransformError) Error 

func (e *TransformError) Error() string

func (*TransformError) Unwrap 

func (e *TransformError) Unwrap() error

type Uint64 added in v0.2.0 

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

Uint64 ungined 64-bit integer

func (*Uint64) AsBigInt added in v0.2.0 

func (i *Uint64) AsBigInt() (bi *big.Int)

AsBigInt Convert to high-precision integer

func (*Uint64) AsDecimal added in v0.2.0 

func (i *Uint64) AsDecimal() decimal.Decimal

AsDecimal Convert to high-precision decimal

func (*Uint64) BigInt added in v0.2.0 

func (i *Uint64) BigInt() BigIntNumber

BigInt Convert to high-precision integer

func (*Uint64) Bool added in v0.2.0 

func (i *Uint64) Bool() (bool, error)

Bool Convert to boolean

func (*Uint64) CloneBigInt added in v0.2.0 

func (i *Uint64) CloneBigInt() BigIntNumber

CloneBigInt Clone high-precision integer

func (*Uint64) CloneDecimal added in v0.2.0 

func (i *Uint64) CloneDecimal() DecimalNumber

CloneDecimal Clone high-precision decimal

func (*Uint64) Decimal added in v0.2.0 

func (i *Uint64) Decimal() DecimalNumber

Decimal Convert to high-precision decimal

func (*Uint64) Float64 added in v0.2.0 

func (i *Uint64) Float64() (float64, error)

Float64 Convert to 64-bit floating-point number. But it will result in loss of precision.

func (*Uint64) Int64 added in v0.2.0 

func (i *Uint64) Int64() (int64, error)

Int64 Convert to 64-bit integer

func (*Uint64) String added in v0.2.0 

func (i *Uint64) String() string

Decimal Convert to 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.