十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
这篇文章主要介绍了如何使用JDBC实现工具类抽取,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
10年积累的成都网站建设、网站建设经验,可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你,你也不认识我。但先网站策划后付款的网站建设流程,更有忻州免费网站建设让你可以放心的选择与我们合作。
1、JDBC工具类抽取
上一篇做了JDBC的基本操作,但是获取连接及释放资源是比较重复的操作,可以抽取工具类而达到代码重用的目的
工程结构如图
JDBC工具类代码
db.properties
driver=com.MySQL.jdbc.Driver url=jdbc:mysql://192.168.47.151:3306/web?useUnicode=true&characterEncoding=utf8 username=root password=root
JDBCUtils.java
package com.rookie.bigdata.util; import java.io.InputStream; import java.sql.*; import java.util.Properties; import java.util.ResourceBundle; /** * Created by dell on 2019/5/22. */ package com.rookie.bigdata.util; import java.io.InputStream; import java.sql.*; import java.util.Properties; import java.util.ResourceBundle; /** * Created by dell on 2019/5/22. */ public class JDBCUtils { private static String driver; private static String url; private static String username; private static String password; // //静态代码块加载配置文件信息 // static { // ResourceBundle db = ResourceBundle.getBundle("db"); // driver = db.getString("driver"); // url = db.getString("url"); // username = db.getString("username"); // password = db.getString("password"); // } //静态代码块加载配置文件信息 static { try { //获取类加载器 ClassLoader classLoader = JDBCUtils.class.getClassLoader(); //通过类加载器的方法获取一个输入流 InputStream resourceAsStream = classLoader.getResourceAsStream("db.properties"); Properties properties = new Properties(); properties.load(resourceAsStream); //获取相关参数的值 driver = properties.getProperty("driver"); url = properties.getProperty("url"); username = properties.getProperty("username"); password = properties.getProperty("password"); } catch (Exception e) { e.printStackTrace(); } } /** * 获取连接 * * @return */ public static Connection getConnection() { Connection conn = null; try { Class.forName(driver); conn = DriverManager.getConnection(url, username, password); } catch (Exception e) { e.printStackTrace(); } return conn; } /** * 释放资源 * @param conn * @param pstmt * @param rs */ public static void relase(Connection conn, PreparedStatement pstmt, ResultSet rs) { if (rs != null) { try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if (pstmt != null) { try { pstmt.close(); } catch (SQLException e) { e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } }
2、批量插入数据
package com.rookie.bigdata; import com.rookie.bigdata.util.JDBCUtils; import java.sql.Connection; import java.sql.PreparedStatement; /** * CREATE TABLE `user` ( * `USERNAME` varchar(30) DEFAULT NULL COMMENT '用户名', * `PASSWORD` varchar(10) DEFAULT NULL COMMENT '密码' * ) ENGINE=InnoDB DEFAULT CHARSET=utf8; */ public class JDBCBatch { public static void main(String[] args) throws Exception { Connection connection = JDBCUtils.getConnection(); //设置自动提交关闭 connection.setAutoCommit(false); PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO USER VALUES (?,?)"); for (int i = 1; i <= 5000; i++) { preparedStatement.setString(1, "张三" + i); preparedStatement.setString(2, "123" + i); preparedStatement.addBatch(); if (i % 1000 == 0) { preparedStatement.executeUpdate(); connection.commit(); preparedStatement.clearBatch(); } } preparedStatement.executeUpdate(); connection.commit(); preparedStatement.clearBatch(); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持创新互联。