tdx2db

After the initial init, use the cron command to update daily data, capital changes, holiday calendars, and online symbol/sector information. This command also recalculates previous close prices and adjustment factors.

Standard update (Daily data):

tdx2db cron --dburi 'duckdb://tdx.db'

Update with 1-minute intraday data: Use the --min flag to download and import 1-minute K-line data.

tdx2db cron --dburi 'duckdb://tdx.db' --min

Important notes for 1-minute data:

• Downloading and importing 1-minute data is time-consuming due to large data volumes.
• TongdaXing does not provide historical 1-minute data; you must provide it yourself if needed.
• If the update interval exceeds 30 days, you must manually fill the gap before continuing.
• Changes in stock codes will not trigger historical record processing.

Download the appropriate compressed package for your platform from the releases page. After extracting, move the binary to your system path to use it globally.

Note: On Windows, macOS, and Linux arm64, the tool will skip the download and import of 1-minute intraday data by default, but daily data will be processed normally.

sudo mv tdx2db /usr/local/bin/ && tdx2db -h

The tdx2db package manages two primary directory locations for temporary and cached data:

• TempDir: The primary location for temporary files. It defaults to the system's cache directory (via utils.GetCacheDir()).
• VipdocDir: A subdirectory located within TempDir (specifically TempDir/vipdoc) used for storing VIP documentation data.

If you change TempDir using OverrideTempDir, VipdocDir is automatically updated to maintain the correct hierarchy.

The --temp flag allows you to override the parent directory used for temporary files. This is useful if your system's default $TMPDIR (like /tmp on many Linux systems) is a tmpfs with limited capacity and you need to use a disk-backed directory instead.

This is a persistent flag, meaning it can be used with any command.

tdx2db --temp /path/to/large/disk/tmp init --dburi 'duckdb://./tdx.db' --dayfiledir /path/to/vipdoc/

The following flags are available globally for the tdx2db CLI:

If you encounter errors regarding database schema versions, it means the version stored in your database file does not match the version required by the current tdx2db binary.

There are two primary error states:

1. Incompatible Version: The database has a major version that differs from the current code's model.SchemaMajor.
   • Error message format: 数据库 schema 版本不兼容 (当前库: v%d.x, 需要: v%d.x)
2. Missing Version: The database does not contain a schema version record.
   • Error message format: 数据库 schema 版本缺失 (需要: v%d.x)

In both cases, you should visit the official releases page to find migration instructions: https://github.com/jing2uo/tdx2db/releases

The Call method is the primary way to send a request to the TDX server. It sends a message with a specific msgID and a byte slice body. It handles the packet framing, transmission, and automatic decompression of the response.

• msgID: A uint16 identifying the specific TDX protocol message type.
• body: The raw byte payload for the request.

Returns the decompressed response body as a []byte or an error.

// Example usage of Call
// msgID and body would be determined by the specific TDX protocol being used
response, err := client.Call(0x1234, []byte{0x01, 0x02, 0x03})
if err != nil {
    // handle error
}
// response contains the unzipped data

To interact with online TDX data, use the OnlineClient type. You must first initialize it with NewOnlineClient() and then establish a connection using either Connect() or ConnectStandard().

• Connect(): Attempts to connect to the primary TDX market hosts (macHosts).
• ConnectStandard(): Attempts to connect to standard TDX market hosts (including Shenzhen, Shanghai, and Beijing dual-line main stations).

Both methods automatically perform a latency check across available hosts and select the fastest available server to connect to.

package main

import "github.com/jing2uo/jing2uo/tdx2db/tdx"

func main() {
    client := tdx.NewOnlineClient()
    
    // Connect to primary hosts
    err := client.Connect()
    if err != nil {
        panic(err)
    }
    defer client.Close()

    // Use the client... 
}

Always call Close() to release the underlying network connection when you are finished with the OnlineClient.

err := client.Close()
if err != nil {
    // handle error
}