java-jdbc

package ojdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Map;

public class GetConnection {
    /**
     * 
     * @projectname  项目名称: Test3
     * @packageclass 包及类名: ojdbc.GetConnection.java
     * @description  功能描述: 返回map数据
     * @author            作        者: zhouzhiwei
     * @param                   参        数: @param sql
     * @param                   参        数: @return
     * @param                   参        数: @throws Exception
     * @return       返回类型: Map
     * @createdate   建立日期: 2015年12月30日下午3:37:36
     */
    @SuppressWarnings({ "unchecked", "rawtypes" })
    public static Map getQueryMap(String sql) throws Exception {
        Map rowData = new HashMap();
        Connection con = null;
        String username =SystemConfigUtil.getValue("username");
        String password =SystemConfigUtil.getValue("password");
        String url =SystemConfigUtil.getValue("url");
        String driver =SystemConfigUtil.getValue("driver");
        try
        {
        Class.forName(driver);//加载驱动程序，此处运用隐式注册驱动程序的方法
        }
        catch(ClassNotFoundException e)
        {
        e.printStackTrace();
        }
        try {
            con = DriverManager.getConnection(url,username,password);// 创建连接对象
        } catch (SQLException e) {
            e.printStackTrace();
        }
        Statement st = con.createStatement();//创建sql执行对象
        ResultSet rs = st.executeQuery(sql);//执行sql语句并返回结果集
        ResultSetMetaData md = rs.getMetaData();
        int num = md.getColumnCount();
        while (rs.next()) {
            for (int i = 1; i <= num; i++) {
            rowData.put(md.getColumnName(i), rs.getObject(i));
          }
        }
        
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (st != null) {
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return rowData;
    }
    /**
     * 
     * @projectname  项目名称: Test3
     * @packageclass 包及类名: ojdbc.GetConnection.java
     * @description  功能描述: 获取数据库连接
     * @author            作        者: zhouzhiwei
     * @param                   参        数: @return
     * @param                   参        数: @throws Exception
     * @return       返回类型: Connection
     * @createdate   建立日期: 2015年12月30日下午3:37:09
     */
    public static Connection getConnection() throws Exception{
        Connection con = null;
        String username =SystemConfigUtil.getValue("username");//读取JDBC_Config_Oracle.properties 文件信息
        String password =SystemConfigUtil.getValue("password");
        String url =SystemConfigUtil.getValue("url");
        String driver =SystemConfigUtil.getValue("driver");
        try
        {
        Class.forName(driver);//加载驱动程序，此处运用隐式注册驱动程序的方法
        }
        catch(ClassNotFoundException e)
        {
        e.printStackTrace();
        }
        try {
            con = DriverManager.getConnection(url,username,password);// 创建连接对象
        } catch (SQLException e) {
            e.printStackTrace();
        }
        if (con != null) {
            try {
                con.close();//关闭连接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return con;
    }
}