Druid连接数据库神器，相关连接数据库方法

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.springframework.jdbc.datasource.DataSourceUtils;

import com.alibaba.druid.pool.DruidDataSource;

public class DBUtil {

/**

 * 获取连接

 * @return

 */

static DruidDataSource dataSource = (DruidDataSource)ApplicationContextHelper.getBean("dataSource"); 

public static Connection getConnection(){

// DruidDataSource dataSource = (DruidDataSource)ApplicationContextHelper.getBean("dataSource"); 

return DataSourceUtils.getConnection(dataSource);

}

/**

 * 获取数据集合

 * @param conn

 * @param sql

 * @param params

 * @return

 */

public static List<Map<String, Object>> getResultToList(String sql, Object... params) {

PreparedStatement ps = null;

Connection conn = getConnection();

ResultSet rs = null;

List<Map<String, Object>> rows = new ArrayList<Map<String, Object>>();

if (null == sql || "".equals(sql)) {

return new ArrayList<Map<String, Object>>();

}

try {

ps = conn.prepareStatement(sql);

if (null != params && params.length > 0) {

for (int i = 0, len = params.length; i < len; i++) {

Object arg = params[i];

ps.setObject(i + 1, arg);

}

}

rs = ps.executeQuery();

if (null != rs) {

ResultSetMetaData rsm = rs.getMetaData();

int count = rsm.getColumnCount();

Map<String, Object> record = null;

if (count > 0) {

while (rs.next()) {

record = new HashMap<String, Object>();

for (int j = 0; j < count; j++) {

Object obj = rs.getObject(j + 1);

String columnName = rsm.getColumnName(j + 1);

record.put(columnName.toLowerCase(),(obj == null) ? "" : obj);

}

rows.add(record);

}

}

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

close(rs, ps, conn);

}

return rows;

}

/**

 * 获取数据集合

 * @param conn

 * @param sql

 * @param params

 * @return

 */

public static List<Map<String, Object>> getResultToList(Connection conn,String sql, Object... params) {

PreparedStatement ps = null;

ResultSet rs = null;

List<Map<String, Object>> rows = new ArrayList<Map<String, Object>>();

if (null == sql || "".equals(sql)) {

return new ArrayList<Map<String, Object>>();

}

try {

ps = conn.prepareStatement(sql);

if (null != params && params.length > 0) {

for (int i = 0, len = params.length; i < len; i++) {

Object arg = params[i];

ps.setObject(i + 1, arg);

}

}

rs = ps.executeQuery();

if (null != rs) {

ResultSetMetaData rsm = rs.getMetaData();

int count = rsm.getColumnCount();

Map<String, Object> record = null;

if (count > 0) {

while (rs.next()) {

record = new HashMap<String, Object>();

for (int j = 0; j < count; j++) {

Object obj = rs.getObject(j + 1);

String columnName = rsm.getColumnName(j + 1);

record.put(columnName.toLowerCase(),(obj == null) ? "" : obj);

}

rows.add(record);

}

}

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

close(rs, ps);

}

return rows;

}

public static String ExectueSqls(Connection conn,String sql,List<List<Object>> b){

boolean flag=false;

int[] rows=new int[b.size()];

PreparedStatement pre=null;

StringBuffer result = new StringBuffer();

try {

  conn.setAutoCommit(false); 

pre=conn.prepareStatement(sql);

for(int i=0,len=b.size();i<len;i++){

List<Object> obj=b.get(i);

for(int j=0,objlen=obj.size();j<objlen;j++){

pre.setObject(j+1, obj.get(j));

}

pre.addBatch();

}

rows=pre.executeBatch();

for(int i=0,len=rows.length;i<len;i++){

if(rows[i]>0||rows[i]==-2){

flag=true;

}else{

flag=false;

result.append((i+1)+"条数据入库："+flag);

}

}

flag=true;

} catch (SQLException e) {

flag=false;

e.getStackTrace();

System.out.println(e.toString());

}finally{

close(pre);

}

System.out.println(flag);

return result.length()!=0?result.toString():"true";

}

//关闭数据源

public static void close(Object...obj){

if(null!=obj){

for(Object o:obj){

try {

if (o instanceof ResultSet) {

((ResultSet) o).close();

} else if (o instanceof Statement) {

((Statement) o).close();

} else if (o instanceof Connection) {

DataSourceUtils.releaseConnection((Connection)o,dataSource);

//((Connection) o).close();

}else if (o instanceof PreparedStatement) {

((PreparedStatement) o).close();

}

} catch (Exception ex) {

ex.printStackTrace();

}

o=null;

}

}

}

/**

 * 获取总条数

 * @param sql

 * @param args

 * @return

 */

public static int getCount(Connection conn,String sql,Object...args){

PreparedStatement pre = null;

ResultSet rs = null;

int total = 0;

String sql2 = "select count(*) from (" + sql + ")   t";

try {

pre = conn.prepareStatement(sql2);

for(int i=0,len=args.length;i<len;i++){

pre.setObject(i+1, args[i]);

}

// pre.setString(1, slid);

rs = pre.executeQuery();

if (rs.next()) {

total = rs.getInt(1);

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

close(pre,rs);

}

return total;

}

/**

 * 获取总条数

 * @param sql

 * @param args

 * @return

 */

public static int getCount(String sql,Object...args){

Connection conn = getConnection();

PreparedStatement pre = null;

ResultSet rs = null;

int total = 0;

String sql2 = "select count(*) from (" + sql + ")   t";

try {

pre = conn.prepareStatement(sql2);

for(int i=0,len=args.length;i<len;i++){

pre.setObject(i+1, args[i]);

}

// pre.setString(1, slid);

rs = pre.executeQuery();

if (rs.next()) {

total = rs.getInt(1);

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

close(rs, pre, conn);

}

return total;

}

public static boolean ExectueSqlList(Connection conn,List<String> sqllist,Object...b){

//批量执行语句

boolean flag=false;

int rows[] = null;

Statement st=null;

try {

conn.setAutoCommit(false); 

st=conn.createStatement();

for (int i = 0; i < sqllist.size(); i++) {

st.addBatch(sqllist.get(i));

}

rows = st.executeBatch();

if(rows[0]>0){

flag=true;

}else{

flag=false;

}

conn.commit();

} catch (SQLException e) {

flag=false;

System.out.println(e.toString());

}finally{

close(st,conn);

}

System.out.println(flag);

return flag;

}

public static boolean ExectueSql(Connection conn,String sql,Object...b){

boolean flag=false;

int rows=0;

PreparedStatement pre=null;

try {

pre=conn.prepareStatement(sql);

for(int i=0,len=b.length;i<len;i++){

pre.setObject(i+1, b[i]);

}

rows=pre.executeUpdate();

if(rows>0){

flag=true;

}else{

flag=false;

}

conn.commit();

} catch (SQLException e) {

flag=false;

System.out.println(e.toString());

}finally{

close(pre);

}

System.out.println(flag);

return flag;

}

public static boolean ExectueSql(String sql,Object...b){

boolean flag=false;

int rows=0;

PreparedStatement pre=null;

Connection conn=getConnection();

try {

pre=conn.prepareStatement(sql);

for(int i=0,len=b.length;i<len;i++){

pre.setObject(i+1, b[i]);

}

rows=pre.executeUpdate();

if(rows>0){

flag=true;

}else{

flag=false;

}

conn.commit();

} catch (SQLException e) {

flag=false;

System.out.println(e.toString());

}finally{

close(pre);

}

System.out.println(flag);

return flag;

}

}