微客导航 » 文章资讯 » java操作Apache druid的实例代码

java操作Apache druid的实例代码

2023-07-11 19:55:04 416

1.添加maven依赖包


org.apache.calcite.avatica
avatica-core
1.15.0

2.编写工具类

packagecom.hnu.druid;

importorg.apache.calcite.avatica.AvaticaConnection;
importorg.apache.calcite.avatica.AvaticaStatement;
importorg.springframework.stereotype.Component;
importjava.sql.DriverManager;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.util.List;
importjava.util.Properties;

/**
*@description:
*@author:YUANHX
*@create:7:11下午
**/
@Component
publicclassDruidJdbcUtil{

privatestaticThreadLocalthreadLocal=newThreadLocal<>();

privatestaticfinalStringDRUID_URL="jdbc:avatica:remote:url=http://172.16.0.160:8888/druid/v2/sql/avatica/";

/**
*打开连接
*@param
*@return
*@throwsSQLException
*/
publicstaticAvaticaConnectionconnection()throwsSQLException{
Propertiesproperties=newProperties();
AvaticaConnectionconnection=(AvaticaConnection)DriverManager.getConnection(DRUID_URL,properties);
threadLocal.set(connection);
returnconnection;
}

/**
*关闭连接
*@throwsSQLException
*/
publicstaticvoidcloseConnection()throwsSQLException{
System.out.println("关闭线程："+threadLocal.get());
AvaticaConnectionconn=threadLocal.get();
if(conn!=null){
conn.close();
threadLocal.remove();
}
}

/**
*根据sql查询结果
*@param
*@paramsql
*@return
*@throwsSQLException
*/
publicstaticResultSetexecuteQuery(Stringsql)throwsSQLException{
AvaticaStatementstatement=connection().createStatement();
ResultSetresultSet=statement.executeQuery(sql);

returnresultSet;

}

/*publicstaticObjectcrud(Stringsql,Classclazz,List

java操作Apache druid的实例代码

热门推荐

随机推荐