PhoenixUtil.java 1.46 KB
package com.cy.report.utils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ResourceBundle;

public class PhoenixUtil {
	//创建链接
	public static Connection getConnection() {
		Connection conn = null;
		try {
			ResourceBundle b = ResourceBundle.getBundle("phoenix");
			Class.forName(b.getString("driver"));
			conn = DriverManager.getConnection(b.getString("url"));
			conn.setAutoCommit(false);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}
	
	//执行查询语句
	public static ResultSet executeQuery(String sql) {
		Connection conn = getConnection();
		Statement statement = null;
		ResultSet rs = null;
		try {
			statement = conn.createStatement();
			//System.out.println(sql);
			rs = statement.executeQuery(sql);
//			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}
	
	public static ResultSet executeQuery(String sql, Connection conn) {
		Statement statement = null;
		ResultSet rs = null;
		try {
			statement = conn.createStatement();
			//System.out.println(sql);
			rs = statement.executeQuery(sql);
//			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}
	
	public static void main(String[] args ){
		Connection connection = getConnection();
		//System.out.println(connection.toString());
	}
}