引言

ClickHose作为一个新的列式数据库，其在实时数仓中作为结果存储的数据库。对于Java程序员来说，我们需要对于ClickHouse进行数据的增删查改，进而支持后续的处理业务。我使用面向对象的思想，实现Java操作ClickHouse的增删改，希望对于学习和使用ClickHouse的你有些帮助。

一、依赖导入

<dependency>
	<groupId>ru.yandex.clickhouse</groupId>
	<artifactId>clickhouse-jdbc</artifactId>
	<version>0.1.52</version>
</dependency>

二、连接实体类

public class ConnEntiy {
    // 驱动器
    String driverName;
    // 连接对象地址
    String url;
    // 用户
    String user;
    // 密码
    String password;

    public ConnEntiy() {
    }

    public ConnEntiy(String driverName, String url, String user, String password) {
        this.driverName = driverName;
        this.url = url;
        this.user = user;
        this.password = password;
    }

    public String getDriverName() {
        return driverName;
    }

    public void setDriverName(String driverName) {
        this.driverName = driverName;
    }

    public String getUrl() {
        return url;
    }

    public void setUrl(String url) {
        this.url = url;
    }

    public String getUser() {
        return user;
    }

    public void setUser(String user) {
        this.user = user;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

三、接口类

public  interface Utils {
    public Connection connection(ConnEntiy connEntiy);

    public void  close(AutoCloseable... closes);
    public boolean insert(Connection connection,String sql,String...params);
    public boolean delete(Connection connection,String sql,String...params);
    public ResultSet QueryResultSet(Connection connection,String sql,String...params);
}

四、接口实现类

public class ClickHouseUtils implements Utils{

    @Override
    public  Connection connection(ConnEntiy connEntiy) {
        Connection conn=null;
        try {
            Class.forName(connEntiy.getDriverName());
            conn= DriverManager.getConnection(connEntiy.getUrl(),connEntiy.getUser(),connEntiy.getPassword());
        }catch(Exception e){
            System.out.println("connection fail ,please check your entities");
        }
        return conn;
    }

    @Override
    public void close(AutoCloseable... closes) {
        for (AutoCloseable close : closes) {
            if (close!=null) {
                try {
                    close.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }finally {
                    close=null;
                }
            }
        }
    }

    @Override
    public boolean  insert(Connection connection, String sql, String... params) {
        boolean b =false;
        ClickHousePreparedStatement pst=null;
        if (connection==null) {
            System.out.println("connection is empty");
            System.exit(-1);
        }
        try {
            pst= (ClickHousePreparedStatement) connection.prepareStatement(sql);
            for (int i = 0; i < params.length; i++) {
                pst.setObject(i+1,params[i]);
            }
            b= pst.execute();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally{
            close(pst,connection);
        }

        return b;
    }

    @Override
    public boolean delete(Connection connection, String sql, String... params) {
        boolean b =false;
        ClickHousePreparedStatement pst=null;
        if (connection==null) {
            System.out.println("connection is empty");
            System.exit(-1);
        }
        try {
            pst= (ClickHousePreparedStatement) connection.prepareStatement(sql);
            for (int i = 0; i < params.length; i++) {
                pst.setObject(i+1,params[i]);
            }
            b= pst.execute();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally{
            close(pst,connection);
        }

        return b;
    }

    @Override
    public ResultSet QueryResultSet(Connection connection, String sql, String... params) {
        ResultSet rst=null;
        ClickHousePreparedStatement pst=null;
        if (connection==null) {
            System.out.println("connection is empty");
            System.exit(-1);
        }
        try {
            pst= (ClickHousePreparedStatement) connection.prepareStatement(sql);
            for (int i = 0; i < params.length; i++) {
                pst.setObject(i+1,params[i]);
            }
            rst = pst.executeQuery();

        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }finally{
            close(rst,pst,connection);
        }
        return rst;
    }
}

五、测试类

public class test {
    public static void main(String[] args)  {
        String driverName="ru.yandex.clickhouse.ClickHouseDriver";
        String url="jdbc:clickhouse://192.168.50.100:9000/test";
        String user="root";
        String password="root";
        String sql="select * from test;";
        String[] params={};
        ConnEntiy connEntiy = new ConnEntiy(driverName, url, user, password);
        Utils utils = new ClickHouseUtils();
        Connection conn = utils.connection(connEntiy);
        utils.insert(conn,sql,params);
    }
}