test

package

v3.0.5 Latest Latest Go to latest Published: Apr 17, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dolphindb/api-go

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AssertEqual(s, d interface{})
func AssertNil(err error)
func CheckmodelTableEqual(t1 *model.Table, t2 *model.Table, n int) bool
func ClearEnv()
func ClearStreamTable(tableName string)
func CompareTables(tableName1 *api.Table, tableName2 *api.Table) bool
func CompareTablesDataformTable(tableName1 *model.Table, tableName2 *api.Table) bool
func CreateDBConnectionPool(threadNumCount int, loadbalance bool) *api.DBConnectionPool
func CreateDatabase(ddb api.DolphinDB, dbPath string, dbhandler string, partitionType string, ...) (*api.Database, error)
func CreateDefPartitionedTable(ddb *api.Database, tableName string, partitionedTableName string, ...) (*api.Table, error)
func CreateDfsCompoRangeHashdb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsCompoRangeListdb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsCompoRangeRangedb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsCompoRangeRangedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)
func CreateDfsCompoRangeValuedb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsDimensiondb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsHashdb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsHashdbChunkGranularity(dbPath string, tableName1 string, tableName2 string)
func CreateDfsListdb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsListdbChunkGranularity(dbPath string, tableName1 string, tableName2 string)
func CreateDfsRangedb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsRangedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)
func CreateDfsValuedb(dbPath string, tableName1 string, tableName2 string)
func CreateDfsValuedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)
func CreateDiskCompoRangeRangedb(dbPath string, tableName1 string, tableName2 string)
func CreateDiskHashdb(dbPath string, tableName1 string, tableName2 string)
func CreateDiskListdb(dbPath string, tableName1 string, tableName2 string)
func CreateDiskRangedb(dbPath string, tableName1 string, tableName2 string)
func CreateDiskUnpartitioneddb(dbPath string, tbName1 string, tbName2 string)
func CreateDiskValuedb(dbPath string, tableName1 string, tableName2 string)
func CreateMemTable(ddb api.DolphinDB, tableName string, colName1 string, colName2 string, ...) (*api.Table, error)
func CreateTable(db *api.Database, tableName string, dimensionTableName string) (*api.Table, error)
func CreateTableWithCapacity(ddb api.DolphinDB, tableName string, capcity int32, size int32, ...) (*api.Table, error)
func Database(ddb api.DolphinDB, dbPath string, dbhandler string) (*api.Database, error)
func DropDatabase(ddb api.DolphinDB, dbPath string) error
func DropPartition(db api.DolphinDB, partitionedTableName string, dbPath string, ...) error
func DropTable(ddb api.DolphinDB, tableName string, dfsDBPath string) error
func ExistsDatabase(ddb api.DolphinDB, dbPath string) (bool, error)
func ExistsTable(ddb api.DolphinDB, dbPath string, tableName string) (bool, error)
func LoadPartitionedTable(db api.DolphinDB, partitionedTableName string, dbPath string) (*api.Table, error)
func LoadTable(ddb api.DolphinDB, tableName string, dbPath string) (*api.Table, error)
func LoadTableBySQL(ddb api.DolphinDB, na string, loadSQL string, dbPath string, ...) (*api.Table, error)
func LoadTableMemoryMode(ddb api.DolphinDB, tableName string, dbPath string, memoryMode bool) (*api.Table, error)
func LoadTablePartitions(ddb api.DolphinDB, tableName string, dbPath string, partitions string) (*api.Table, error)
func LoadTextDelimiter(ddb api.DolphinDB, remoteFilePath string, delimiter string) (*api.Table, error)
func LoadTextFileName(ddb api.DolphinDB, remoteFilePath string) (*api.Table, error)
func PloadTextDelimiter(ddb api.DolphinDB, remoteFilePath string, delimiter string) (*api.Table, error)
func PloadTextFileName(ddb api.DolphinDB, remoteFilePath string) (*api.Table, error)
func SaveTable(ddb api.DolphinDB, dbPath string, tableName string, dbhandler string) error
func SaveText(ddb api.DolphinDB, obj string, remoteFilePath string) error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DfsDBPath    = "dfs://test_dfsTable"
	TbName1      = "tb1"
	TbName2      = "tb2"
	DfsTBName1   = "pt1"
	DfsTBName2   = "pt2"
	DiskDBPath   = setup.WORK_DIR + `/testTable`
	DBhandler    = "db"
	MemTableName = "memTable"
)

Functions ¶

func AssertEqual ¶

func AssertEqual(s, d interface{})

func AssertNil ¶

func AssertNil(err error)

func CheckmodelTableEqual ¶

func CheckmodelTableEqual(t1 *model.Table, t2 *model.Table, n int) bool

func ClearEnv ¶

func ClearEnv()

func ClearStreamTable ¶

func ClearStreamTable(tableName string)

func CompareTables ¶

func CompareTables(tableName1 *api.Table, tableName2 *api.Table) bool

func CompareTablesDataformTable ¶

func CompareTablesDataformTable(tableName1 *model.Table, tableName2 *api.Table) bool

func CreateDBConnectionPool ¶

func CreateDBConnectionPool(threadNumCount int, loadbalance bool) *api.DBConnectionPool

func CreateDatabase ¶

func CreateDatabase(ddb api.DolphinDB, dbPath string, dbhandler string, partitionType string, partitionScheme string, location string, engineType string, atomic string) (*api.Database, error)

func CreateDefPartitionedTable ¶

func CreateDefPartitionedTable(ddb *api.Database, tableName string, partitionedTableName string, partitioncolumns []string) (*api.Table, error)

func CreateDfsCompoRangeHashdb ¶

func CreateDfsCompoRangeHashdb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsCompoRangeListdb ¶

func CreateDfsCompoRangeListdb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsCompoRangeRangedb ¶

func CreateDfsCompoRangeRangedb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsCompoRangeRangedbChunkGranularity ¶

func CreateDfsCompoRangeRangedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)

func CreateDfsCompoRangeValuedb ¶

func CreateDfsCompoRangeValuedb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsDimensiondb ¶

func CreateDfsDimensiondb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsHashdb ¶

func CreateDfsHashdb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsHashdbChunkGranularity ¶

func CreateDfsHashdbChunkGranularity(dbPath string, tableName1 string, tableName2 string)

func CreateDfsListdb ¶

func CreateDfsListdb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsListdbChunkGranularity ¶

func CreateDfsListdbChunkGranularity(dbPath string, tableName1 string, tableName2 string)

func CreateDfsRangedb ¶

func CreateDfsRangedb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsRangedbChunkGranularity ¶

func CreateDfsRangedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)

func CreateDfsValuedb ¶

func CreateDfsValuedb(dbPath string, tableName1 string, tableName2 string)

func CreateDfsValuedbChunkGranularity ¶

func CreateDfsValuedbChunkGranularity(dbPath string, tableName1 string, tableName2 string)

func CreateDiskCompoRangeRangedb ¶

func CreateDiskCompoRangeRangedb(dbPath string, tableName1 string, tableName2 string)

func CreateDiskHashdb ¶

func CreateDiskHashdb(dbPath string, tableName1 string, tableName2 string)

func CreateDiskListdb ¶

func CreateDiskListdb(dbPath string, tableName1 string, tableName2 string)

func CreateDiskRangedb ¶

func CreateDiskRangedb(dbPath string, tableName1 string, tableName2 string)

func CreateDiskUnpartitioneddb ¶

func CreateDiskUnpartitioneddb(dbPath string, tbName1 string, tbName2 string)

func CreateDiskValuedb ¶

func CreateDiskValuedb(dbPath string, tableName1 string, tableName2 string)

func CreateMemTable ¶

func CreateMemTable(ddb api.DolphinDB, tableName string, colName1 string, colName2 string, colName3 string, colName4 string, dataList1 string, dataList2 string, dataList3 string, dataList4 string) (*api.Table, error)

func CreateTable ¶

func CreateTable(db *api.Database, tableName string, dimensionTableName string) (*api.Table, error)

func CreateTableWithCapacity ¶

func CreateTableWithCapacity(ddb api.DolphinDB, tableName string, capcity int32, size int32, colName []string, typeName []string) (*api.Table, error)

func Database ¶

func Database(ddb api.DolphinDB, dbPath string, dbhandler string) (*api.Database, error)

func DropDatabase ¶

func DropDatabase(ddb api.DolphinDB, dbPath string) error

func DropPartition ¶

func DropPartition(db api.DolphinDB, partitionedTableName string, dbPath string, partitionPaths string) error

func DropTable ¶

func DropTable(ddb api.DolphinDB, tableName string, dfsDBPath string) error

func ExistsDatabase ¶

func ExistsDatabase(ddb api.DolphinDB, dbPath string) (bool, error)

func ExistsTable ¶

func ExistsTable(ddb api.DolphinDB, dbPath string, tableName string) (bool, error)

func LoadPartitionedTable ¶

func LoadPartitionedTable(db api.DolphinDB, partitionedTableName string, dbPath string) (*api.Table, error)

func LoadTable ¶

func LoadTable(ddb api.DolphinDB, tableName string, dbPath string) (*api.Table, error)

func LoadTableBySQL ¶

func LoadTableBySQL(ddb api.DolphinDB, na string, loadSQL string, dbPath string, partitionedTableName string) (*api.Table, error)

func LoadTableMemoryMode ¶

func LoadTableMemoryMode(ddb api.DolphinDB, tableName string, dbPath string, memoryMode bool) (*api.Table, error)

func LoadTablePartitions ¶

func LoadTablePartitions(ddb api.DolphinDB, tableName string, dbPath string, partitions string) (*api.Table, error)

func LoadTextDelimiter ¶

func LoadTextDelimiter(ddb api.DolphinDB, remoteFilePath string, delimiter string) (*api.Table, error)

func LoadTextFileName ¶

func LoadTextFileName(ddb api.DolphinDB, remoteFilePath string) (*api.Table, error)

func PloadTextDelimiter ¶

func PloadTextDelimiter(ddb api.DolphinDB, remoteFilePath string, delimiter string) (*api.Table, error)

func PloadTextFileName ¶

func PloadTextFileName(ddb api.DolphinDB, remoteFilePath string) (*api.Table, error)

func SaveTable ¶

func SaveTable(ddb api.DolphinDB, dbPath string, tableName string, dbhandler string) error

func SaveText ¶

func SaveText(ddb api.DolphinDB, obj string, remoteFilePath string) error

Types ¶

This section is empty.

Source Files ¶

View all Source files

util.go

Directories ¶

Path	Synopsis
setup
streaming

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