java操作Apache druid的实例代码

1. 添加maven依赖包

<dependency>
  <groupId>org.apache.calcite.avatica</groupId>
  <artifactId>avatica-core</artifactId>
  <version>1.15.0</version>
</dependency>

2. 编写工具类

package com.hnu.druid;

import org.apache.calcite.avatica.AvaticaConnection;
import org.apache.calcite.avatica.AvaticaStatement;
import org.springframework.stereotype.Component;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Properties;

/**
 * @description:
 * @author: YUANHX
 * @create: 7:11 下午
 **/
@Component
public class DruidJdbcUtil {

  private static ThreadLocal<AvaticaConnection> threadLocal = new ThreadLocal<>();

  private static final String DRUID_URL = "jdbc:avatica:remote:url=http://172.16.0.160:8888/druid/v2/sql/avatica/";

  /**
   * 打开连接
   * @param
   * @return
   * @throws SQLException
   */
  public static AvaticaConnection connection() throws SQLException {
    Properties properties = new Properties();
    AvaticaConnection connection = (AvaticaConnection) DriverManager.getConnection(DRUID_URL, properties);
    threadLocal.set(connection);
    return connection;
  }

  /**
   * 关闭连接
   * @throws SQLException
   */
  public static void closeConnection() throws SQLException{
    System.out.println("关闭线程："+threadLocal.get());
    AvaticaConnection conn = threadLocal.get();
    if(conn != null){
      conn.close();
      threadLocal.remove();
    }
  }

  /**
   * 根据sql查询结果
   * @param
   * @param sql
   * @return
   * @throws SQLException
   */
  public static ResultSet executeQuery (String sql) throws SQLException{
    AvaticaStatement statement = connection().createStatement();
    ResultSet resultSet = statement.executeQuery(sql);

    return resultSet;

  }

  /*public static Object crud(String sql, Class clazz, List<Object> params) throws SQLException{
    AvaticaStatement statement = connection().createStatement();
    Object obj = null;
    for (int i = 0; i < params.size(); i++) {
      statement.set
    }
    return obj;
  }*/

  public static void main(String[] args) {
    try {
      String sql = "SELECT * FROM \"vehicleCondition\" limit 20";
      for (int i = 0; i < 5; i++) {
        ResultSet resultSet = executeQuery(sql);
        System.out.println("开始连接"+i + ";  连接线程："+threadLocal.get());
        while(resultSet.next()){
          String equipmentCode = resultSet.getString("EquipmentCode");
          String vkaCode = resultSet.getString("VKACode");
//          System.out.println(equipmentCode + "  ;  "+ vkaCode);
        }
        closeConnection();
      }

    } catch (SQLException throwables) {
      throwables.printStackTrace();
    }
  }
}

到此这篇关于java操作Apache druid的实例代码的文章就介绍到这了,更多相关java操作Apache druid内容请搜索呐喊教程以前的文章或继续浏览下面的相关文章希望大家以后多多支持呐喊教程！

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：notice#nhooo.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。