ClickHouse数据库之JDBC篇

package com.bibichuan.bigdata.Clickhouse;

import org.springframework.stereotype.Component;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

@Component
public class ClickhouseDbUtil {
    public static final String URL = "jdbc:clickhouse://192.168.1.90:8123/lsmfhx";
    public static final String USER = "admin";
    public static final String PASSWORD = "1q2w3e4r.";

    public Connection coon=null;

    public ClickhouseDbUtil(){
        try{
            //1.加载驱动程序
            Class.forName("cc.blynk.clickhouse.ClickHouseDriver");
            //2. 获得数据库连接
            this.coon = DriverManager.getConnection(URL, USER, PASSWORD);
            //3.操作数据库，实现增删改查
            Statement stmt = this.coon.createStatement();

            ResultSet rs = stmt.executeQuery("SELECT * FROM realtime where id=443");
            //如果有数据，rs.next()返回true
            while(rs.next()){
                System.out.println(rs.getString("SiteNo")+" 年龄："+rs.getInt("Alarm"));
            }
        }catch (Exception e){
            System.out.println(e);
        }
    }
    // 执行sql语句
    public ResultSet executeSql(String sql){
        ResultSet resultSet=null;
        try{
            Statement stmt = this.coon.createStatement();

            resultSet = stmt.executeQuery(sql);

        }catch (Exception e){
            System.out.println(e);
        }
        return resultSet;

    }
}