ClickHouse学习(十一)clickhouseAPI操作

---

创建maven

在pom中加入clickhouse依赖

    <!-- Clickhouse -->
        <dependency>
            <groupId>ru.yandex.clickhouse</groupId>
            <artifactId>clickhouse-jdbc</artifactId>
            <version>0.3.1</version>
        </dependency>

编写API

import java.sql.*;

/** * @author 公羽 * date: 2021/8/19 * desc: 简单api编写 */
public class ClickHouse_Select {
    
    public static void main(String[] args) throws SQLException {
    
        Connection connection = null;
        PreparedStatement preparedStatement =null;
        ResultSet resultSet =null;
        try {
    
// TODO 1.加载驱动类
            Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
// TODO 2.创建连接
            connection = DriverManager.getConnection("jdbc:clickhouse://spark01:8123");
// TODO 3.创建PreparedStatement对象
            preparedStatement = connection.prepareStatement("select * from test_binlog.user");
// TODO 4.执行
            resultSet = preparedStatement.executeQuery();
// TODO 5.输出结果
            System.out.println(resultSet);

        } catch (ClassNotFoundException | SQLException e) {
    
            e.printStackTrace();
        } finally {
    
            connection.close();
            preparedStatement.close();
            resultSet.close();
        }
    }
}

删除,插入操作都类似只是修改prepareStatement()中的语句就行