Skip to content

Commit 93962d7

Browse files
author
Paultagoras
committed
Update JDBCInsert.java
1 parent 59d214a commit 93962d7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

performance/src/test/com/clickhouse/benchmark/clients/JDBCInsert.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,13 +10,15 @@
1010
import java.util.List;
1111
import java.util.stream.Collectors;
1212

13+
import static com.clickhouse.benchmark.TestEnvironment.DB_NAME;
14+
1315
public class JDBCInsert extends BenchmarkBase {
1416
private static final Logger LOGGER = LoggerFactory.getLogger(JDBCInsert.class);
1517
void insetData(Connection connection, DataState dataState) throws SQLException {
1618
int size = dataState.dataSet.getSchema().getColumns().size();
1719
String names = dataState.dataSet.getSchema().getColumns().stream().map(column -> column.getColumnName()).collect(Collectors.joining(","));
1820
String values = dataState.dataSet.getSchema().getColumns().stream().map(column -> "?").collect(Collectors.joining(","));
19-
String sql = String.format("INSERT INTO %s (%s) VALUES (%s)", dataState.tableNameEmpty, names, values);
21+
String sql = String.format("INSERT INTO `%s`.`%s` (%s) VALUES (%s)", DB_NAME ,dataState.tableNameEmpty, names, values);
2022
LOGGER.info("SQL: " + sql);
2123
PreparedStatement preparedStatement = connection.prepareStatement(sql);
2224
for (List<Object> data : dataState.dataSet.getRowsOrdered()) {

0 commit comments

Comments
 (0)