clickhouse-java

clickhouse-java copied to clipboard

Pass ClickHouse Skip Index parameters while creating Table in ClickHouse from Spark

1

### What I am doing? I am currently writing a dataframe into clickhouse from PySpark using ClickHouse-jdbc driver. The table is not originally present and it is dynamically created while...

swarupsarangi113

Need to insert an Array of Integers into ClickHouse Table Column from Spark :: Can't get JDBC type for array<int>

5

### OS Windows 11 Spark 3.1.2 Python 3.7 ### What I am doing ? I have a dataframe that contains an Array of Integers in a column. I am inserting...

swarupsarangi113

jdbc isn't allows to insert shorter string into FixedString field

1

The field declared as `FixedString(2)` ```sql CREATE TABLE test ( country FixedString(2) ) ENGINE = MergeTree() PRIMARY KEY (country) ORDER BY (country) ; ``` If we tried to insert data...

TheHett

[FEATURE REQUEST] ClickHouseValue return ClickHouseValue data for nested types

3

e.g. for array type ``` interface ClickHouseValue { Object[] asArray() T[] asArray(Class clazz) // wanted ClickHouseValue[] asArrayValues() } ```

pan3793

Selecting huge numbers gives incorrect results

1

Driver version v0.3.2-patch11 Selecting some huge numbers gives incorrect results. For example: `SELECT toUInt64(15369343623947579499) a, toNullable(15369343623947579499) b;` in dBeaver:  in DataGrip: 

ne1r0n

why not supports multi query?

2

com.clickhouse.jdbc.internal.ClickHouseConnectionImpl#prepareStatement: Prepared statement only supports one query but we got

stevenlsj

Writing data to Clickhouse(20.6.3.28,22.8.4.7) using Flink(1.14.5) causes data duplication

2

JDBC 0.3.2+ can cause such problems. this is my code ` public void createConnection() throws Exception { String insertStr = insertStr(this.tableColums); String url = "jdbc:clickhouse://" + host + "?socket_timeout=300000"; Connection...

2309859381

This reminds that probably we need to promote FakeTransaction from clickhouse-jdbc to clickhouse-client, so that it can be reused in R2DBC as well. This is something we need to refactor...

rernas35

We need to declare a constant to reuse in both JDBC and R2DBC driver. This can be updated later. https://github.com/rernas35/clickhouse-jdbc/blob/41e1afc89c4c5aa6c1e6874148545086deca9d06/clickhouse-r2dbc/src/main/java/com/clickhouse/r2dbc/connection/ClickHouseConnectionMetadata.java#L28

rernas35

Fetch size should impact buffer size and maybe maximum queued buffers etc. I can fix this together with JDBC driver after merging the initial PR. https://github.com/rernas35/clickhouse-jdbc/blob/41e1afc89c4c5aa6c1e6874148545086deca9d06/clickhouse-r2dbc/src/main/java/com/clickhouse/r2dbc/ClickHouseStatement.java#L129

rernas35