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()中的语句就行