zoukankan      html  css  js  c++  java
  • JDBC工具类

    package com.shundong.uitl;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    public class DBCon {
    	public static final String DRIVER="com.mysql.jdbc.Driver";
    	public static final String URL="jdbc:mysql://127.0.0.1:3306/loginSys?characterEncoding=UTF-8";
    	public static final String USER="root";
    	public static final String PWD="root";
    	private Connection con;
    	private PreparedStatement ps;
    	private ResultSet rs;
    	
    	
    	public DBCon(){
    		try {
    			//加载驱动程序
    			Class.forName(DRIVER);
    		} catch (ClassNotFoundException e) {
    			e.printStackTrace();
    		}
    	}
    	/**
    	 * @return返回数据库连接
    	 */
    	public Connection getCon(){
    		try {
    			con=DriverManager.getConnection(URL, USER, PWD);
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		return con;
    	}
    	
    	/**
    	 * 关闭资源 
    	 */
    	public void closeAll(){
    		if(rs!=null){
    			try {
    				rs.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    		if(ps!=null)
    			try {
    				ps.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		if(con!=null)
    			try {
    				con.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    	}
    	
    	/**
    	 * @param sqlsql语句 
    	 * @param pras参数列表 
    	 * @return受影响的条数
    	 */
    	public int update(String sql,Object... pras){
    		int resu=0;
    		con=getCon();
    		try {
    			ps=con.prepareStatement(sql);
    			if(pras!=null){
    				for(int i=0;i<pras.length;i++){
    					ps.setObject(i+1, pras[i]);
    				}
    			}
    			resu=ps.executeUpdate();
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}finally{
    			closeAll();
    		}
    		return resu;
    	}
    	
    	
    	/**
    	 * @param sql sql语句 
    	 * @param pras
    	 * @return 结果集
    	 */
    	public ResultSet query(String sql,Object... pras){
    		con=getCon();
    		try {
    			ps=con.prepareStatement(sql);
    			if(pras!=null){
    				for(int i=0;i<pras.length;i++){
    					ps.setObject(i+1, pras[i]);
    				}
    			}
    			rs=ps.executeQuery();
    		} catch (SQLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		return rs;
    	}
    }
    

      

  • 相关阅读:
    物联网架构成长之路(11)-Redis缓存主从复制
    物联网架构成长之路(10)-Nginx负载均衡
    物联网架构成长之路(9)-双机热备Keepalived了解
    物联网架构成长之路(8)-EMQ-Hook了解、连接Kafka发送消息
    2017年年度总结
    物联网架构成长之路(7)-EMQ权限验证小结
    物联网架构成长之路(6)-EMQ权限控制
    物联网架构成长之路(5)-EMQ插件配置
    物联网架构成长之路(4)-EMQ插件创建
    物联网架构成长之路(3)-EMQ消息服务器了解
  • 原文地址:https://www.cnblogs.com/shundong106/p/9791092.html
Copyright © 2011-2022 走看看