zoukankan      html  css  js  c++  java
  • JdbcUtils

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class JdbcUtils
    {
        private final static String dbdriver = "com.mysql.jdbc.Driver";
        private final static String dburl = "jdbc:mysql://localhost:3306/study1?seUnicode=true&characterEncoding=UTF8";
        private final static String dbusername = "root";
        private final static String dbpassword = "root";
        static
        {
            try
            {
                Class.forName(dbdriver);
            } catch (ClassNotFoundException e)
            {
                throw new ExceptionInInitializerError(e);
            }
        }
    
        public static Connection createConnection() throws SQLException
        {
            return DriverManager.getConnection(dburl, dbusername, dbpassword);
        }
    
        public static void close(Connection conn)
        {
            if (conn != null)
            {
                try
                {
                    conn.close();
                } catch (SQLException e)
                {
    
                }
            }
        }
    
        public static void close(Statement stmt)
        {
            if (stmt != null)
            {
                try
                {
                    stmt.close();
                } catch (SQLException e)
                {
    
                }
            }
        }
    
        public static void close(ResultSet rs)
        {
            if (rs != null)
            {
                try
                {
                    rs.close();
                } catch (SQLException e)
                {
    
                }
            }
        }
    
        public static int executeUpdate(String sql, Object... parameters)
                throws SQLException
        {
            Connection conn = null;
            try
            {
                conn = createConnection();
                return executeUpdate(conn, sql, parameters);
            } finally
            {
                close(conn);
            }
        }
    
        public static int executeUpdate(Connection conn, String sql,
                Object... parameters) throws SQLException
        {
            PreparedStatement ps = null;
            try
            {
                ps = conn.prepareStatement(sql);
                for (int i = 0; i < parameters.length; i++)
                {
                    ps.setObject(i + 1, parameters[i]);
                }
                return ps.executeUpdate();
            } finally
            {
                close(ps);
            }
        }
    
        public static ResultSet executeQuery(String sql, Object... parameters)
                throws SQLException
        {
            Connection conn = null;
            try
            {
                conn = createConnection();
                return executeQuery(conn, sql, parameters);
            } catch (SQLException ex)
            {
                close(conn);
                throw ex;
            }
        }
    
        public static ResultSet executeQuery(Connection conn, String sql,
                Object... parameters) throws SQLException
        {
            PreparedStatement ps = null;
            try
            {
                ResultSet rs = null;
                ps = conn.prepareStatement(sql);
                for (int i = 0; i < parameters.length; i++)
                {
                    ps.setObject(i + 1, parameters[i]);
                }
                rs = ps.executeQuery();
                return rs;
            } catch (SQLException ex)
            {
                close(ps);
                throw ex;
            }
        }
    
        public static void closeAll(ResultSet rs)
        {
            if (rs == null)
            {
                return;
            }
            try
            {
                close(rs.getStatement().getConnection());
                close(rs.getStatement());
                close(rs);
            } catch (SQLException e)
            {
    
            }
        }
        
        public static void rollback(Connection conn)
        {
            try
            {
                conn.rollback();
            } catch (SQLException e)
            {
                //
            }
        }
    }
  • 相关阅读:
    ASP.NET使用UEditor入门与常见问题
    关于发布者策略程序集学习记录
    Myeclipse 10安装,以及Flex4插件(原)
    IE、Chrome等浏览器实现PDF预览(原)
    Oracle数据库中文显示乱码的最简单解决办法
    关于程序集的结构(2)C#和.NET2.0实战学习笔记
    关于AppDomain
    关于强名称程序集 C#和.NET2.0实战学习记录
    数据库查询·聚合分支格式化日期·思维导图&要点&误点(含示例)
    如何在SERVER2003上安装MySQL?(附安装教程及资源地址)
  • 原文地址:https://www.cnblogs.com/renjing/p/JdbcUtils.html
Copyright © 2011-2022 走看看