Simple Log Service：使用PostgreSQL協議接入SLS

pg用戶端，使用以下URL格式串連SLS：

postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}
# 串連預設會開啟TLS串連（認證採用MD5），若要顯式關閉TLS（比如用戶端不支援），可以指定sslmode參數為disable
postgresql://{AccessKey_ID}:{AccessKey_Secret}@{Endpoint}:5432/{Project_Name}?sslmode=disable

通過JDBC的方式採用postgres協議串連SLS時，則可以採用如下配置：

private static final String URL = "jdbc:postgresql://{Endpoint}:5432/{Project_Name}?preferQueryMode=simple";
private static final String AccessKey_ID = "xyz";
private static final String AccessKey_Secret = "123456";

public static void main(String[] args) throws Exception
{
    Properties props = new Properties();
    props.setProperty(PGProperty.USER.getName(), AccessKey_ID);
    props.setProperty(PGProperty.PASSWORD.getName(), AccessKey_Secret);

    try (Connection conn = DriverManager.getConnection(URL, props)) {
        System.out.println("串連成功！");
    }
}

參數說明：

建立Table

使用CREATE TABLE語句建立LogStore：

CREATE TABLE users (
    id           BIGINT,
    name         TEXT,
    create_time  TIMESTAMP
)
WITH (
    shard_count = 4,
    ttl = 14,
    default_query_range = '1d',
    full_text_search_enabled = true,

    index_tokens = '&[ ]",''\',

    log_time_field = 'create_time',
    insert_any_allowed = false
);

支援的列類型：

Table屬性（WITH子句）：

修改Column

支援以下Column修改操作：

新增Column：

ALTER TABLE users ADD COLUMN change_time TEXT;

重新命名Column：

ALTER TABLE users RENAME COLUMN change_time TO update_time;

修改Column類型：

ALTER TABLE users ALTER COLUMN update_time TYPE TIMESTAMP;

刪除Column：

ALTER TABLE users DROP COLUMN update_time;

清除資料

使用TRUNCATE語句清除Table中的所有資料：

TRUNCATE TABLE users;

說明：資料刪除後，SQL可見度需要約30秒才會生效。

刪除Table

使用DROP TABLE語句刪除Table（對應刪除LogStore）：

DROP TABLE users;

基本查詢

使用標準SQL SELECT語句查詢資料：

SELECT id, name FROM users LIMIT 10;

說明：如果SQL中沒有指定查詢時間範圍，將使用default_query_range指定的預設時間範圍。如果建立Table時未設定default_query_range，預設查詢最近15分鐘的資料。

指定查詢時間範圍

您可以通過以下兩種方式指定查詢時間範圍：

-- 指定查詢時間下限
SELECT id, name FROM users 
WHERE __time__ > 1766646000
LIMIT 10;

-- 指定查詢時間範圍
SELECT id, name FROM users 
WHERE __time__ > 1766646000 AND __time__ < 1766646987
LIMIT 10;

-- 設定查詢時間下限
SET query_begin = 1766646000; 
SELECT id, name FROM users LIMIT 10;

-- 設定查詢時間範圍
SET query_begin = 1766646000; 
SET query_end = 1766646987; 
SELECT id, name FROM users LIMIT 10;

-- 在單條語句中設定（推薦）
SET query_begin = 1766646000; SET query_end = 1766646987; SELECT id, name FROM users LIMIT 10;

基本寫入

使用INSERT INTO語句寫入資料：

INSERT INTO users (id, name, create_time) 
VALUES
    (1, 'Name#1', '2025-12-25T06:54:19'),
    (2, 'Name#2', '2025-12-25T06:54:20'),
    (3, 'Name#3', '2025-12-25T06:54:21');

EXACTLY ONCE寫入

SLS PostgreSQL協議不支援唯一性限制式（如主鍵），但支援EXACTLY ONCE的寫入方式，確保資料唯寫入一次。

使用hash_key和seq_id變數實現EXACTLY ONCE寫入：

SET hash_key = 'file#1'; 
SET seq_id = 1; 
INSERT INTO users (id, name, create_time) 
VALUES
    (1, 'Name#1', '2025-12-25T06:54:19'),
    (2, 'Name#2', '2025-12-25T06:54:20'),
    (3, 'Name#3', '2025-12-25T06:54:21');

參數說明：

重複資料錯誤處理：

當寫入重複資料時，服務端會返回如下格式的錯誤資訊：

error: sequence id is lower than expected, hash_key=xyz,current sequence_id=100,requested sequence_id=90

您可以使用以下Regex提取服務端當前的seq_id：

current\s+sequence_id=(\d+)

查詢所有LogStore

SELECT 
    table_schema, 
    table_name
FROM 
    information_schema.tables;

說明：LogStore預設映射在同名Project的schema下。

查詢欄位結構

SELECT 
    column_name, 
    data_type
FROM 
    information_schema.columns 
WHERE 
    table_name = 'access_log';