OCEAN 2 месяцев назад
Родитель
Сommit
f4735534a6
4 измененных файлов: 1258 добавлений и 82 удалений
  1. +90
    -2
      tcp_client/config.toml
  2. +1168
    -80
      tcp_server/src/main.rs
  3. Двоичные данные
      tcp_server/target/debug/tcp_server.exe
  4. Двоичные данные
      tcp_server/target/debug/tcp_server.pdb

+ 90
- 2
tcp_client/config.toml Просмотреть файл

@@ -4,7 +4,7 @@ host = "127.0.0.1"
port = 9090

[client]
max_retries = 3
max_retries = 2
retry_delay_secs = 3
read_timeout_secs = 5
write_timeout_secs = 5
@@ -17,6 +17,7 @@ user = "postgres"
password = "Auseft@2025qwer"

# 要同步的表配置

[[tables]]
name = "hy_instrument"
query = "SELECT * FROM \"hy_instrument\""
@@ -33,4 +34,91 @@ key_field = "UpdateTime"
name = "hy_record"
query = "SELECT * FROM \"hy_record\""
incremental = false # 是否增量同步
key_field = "UpdateTime" # 增量同步的时间字段
key_field = "UpdateTime" # 增量同步的时间字段




[[tables]]
name = "hy_allot"
query = "SELECT * FROM \"hy_allot\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_cytask"
query = "SELECT * FROM \"hy_cytask\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_fullwatersample"
query = "SELECT * FROM \"hy_fullwatersample\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_informationnorm"
query = "SELECT * FROM \"hy_informationnorm\""
incremental = false
key_field = "UpdateTime"



[[tables]]
name = "hy_itemdetail"
query = "SELECT * FROM \"hy_itemdetail\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_laboratoryinstrument"
query = "SELECT * FROM \"hy_laboratoryinstrument\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_materialanalysis_type"
query = "SELECT * FROM \"hy_materialanalysis_type\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_materialdetail"
query = "SELECT * FROM \"hy_materialdetail\""
incremental = false
key_field = "UpdateTime"


[[tables]]
name = "hy_norm"
query = "SELECT * FROM \"hy_norm\""
incremental = false
key_field = "UpdateTime"


[[tables]]
name = "hy_weight_input"
query = "SELECT * FROM \"hy_weight_input\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_warmhumid"
query = "SELECT * FROM \"hy_warmhumid\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_task"
query = "SELECT * FROM \"hy_task\""
incremental = false
key_field = "UpdateTime"

[[tables]]
name = "hy_spotcheck"
query = "SELECT * FROM \"hy_spotcheck\""
incremental = false
key_field = "UpdateTime"



+ 1168
- 80
tcp_server/src/main.rs
Разница между файлами не показана из-за своего большого размера
Просмотреть файл


Двоичные данные
tcp_server/target/debug/tcp_server.exe Просмотреть файл


Двоичные данные
tcp_server/target/debug/tcp_server.pdb Просмотреть файл


Загрузка…
Отмена
Сохранить