Неожиданное поведение при сохранении значения в десятичном столбце в clickhouse - PullRequest
Новая
       39

Неожиданное поведение при сохранении значения в десятичном столбце в clickhouse

0 голосов
/ 08 января 2020

При сохранении значения (0,0003) в десятичном столбце (Decimal (12,4)) в Clickhouse, сохраненное значение было 0,0002.
Почему оно ведет себя так?
Но когда я вставил с помощью SQL, я смог сохранить его без проблем.
Что означает, что написанная мною программа go неверна?

■ создать таблицу 

CREATE TABLE test_ch (
    id Decimal(12,4),
    created_at DateTime
) ENGINE = MergeTree() PARTITION BY toYYYYMMDD(created_at) ORDER BY (created_at);

■ источник 

import (
    "database/sql"
    "fmt"
    "time"

    "github.com/ClickHouse/clickhouse-go"
    sq "github.com/Masterminds/squirrel"
)

var ConnectCH *sql.DB

func main() {
    SetClickHouse()
    insert()
}

func insert() error {
    return Exec(func(tx *sql.Tx) error {
        prepare, _, _ := sq.Insert("test_ch").
            Columns(
                "id",
                "created_at",
            ).Values().ToSql()
        stmt, _ := tx.Prepare(prepare)

        createdAt := time.Now().Format("2006-01-02 15:04:05")
        if _, err := stmt.Exec(
            0.0003,
            createdAt,
        ); err != nil {
            return err
        }
        return nil
    })
}

func recoverAndRollback(tx *sql.Tx) {
    if r := recover(); r != nil {
        tx.Rollback()
    }
}

func Exec(t func(*sql.Tx) error) error {
    tx, err := ConnectCH.Begin()
    if err != nil {
        tx.Rollback()
        return err
    }
    defer recoverAndRollback(tx)
    if err := t(tx); err != nil {
        tx.Rollback()
        return err
    }
    if err := tx.Commit(); err != nil {
        tx.Rollback()
        return err
    }
    return nil
}

func SetClickHouse() error {
    var err error

    url := fmt.Sprintf("tcp://%s:%s", "clickhouse", "9000")
    ConnectCH, err = sql.Open("clickhouse", url)
    if err != nil {
        return err
    }

    if err := ConnectCH.Ping(); err != nil {
        if exception, ok := err.(*clickhouse.Exception); ok {
            fmt.Printf("[%d] %s \n%s\n", exception.Code, exception.Message, exception.StackTrace)
        } else {
            fmt.Println(err)
        }
        return err
    }

    return nil
}

■ выход

при id = 0,0001 
SELECT *
FROM test_ch

┌─────id─┬──────────created_at─┐
│ 0.0001 │ 2020-01-09 01:58:49 │
└────────┴─────────────────────┘

в порядке

при id = 0,0002 
SELECT *
FROM test_ch

┌─────id─┬──────────created_at─┐
│ 0.0002 │ 2020-01-09 01:59:33 │
└────────┴─────────────────────┘

в порядке

при id = 0,0003 
SELECT *
FROM test_ch

┌─────id─┬──────────created_at─┐
│ 0.0002 │ 2020-01-09 02:00:30 │
└────────┴─────────────────────┘

Почему 0,0002?

1 Ответ

0 голосов
/ 09 января 2020

производительность 

SELECT CAST(toFloat64('0.0003'), 'Decimal(12, 8)')    
┌─CAST(toFloat64('0.0003'), 'Decimal(12, 8)')─┐
│                                  0.00029999 │
└─────────────────────────────────────────────┘


SELECT CAST('0.0003', 'Decimal(12, 8)')
┌─CAST('0.0003', 'Decimal(12, 8)')─┐
│                       0.00030000 │
└──────────────────────────────────┘
...