时间:2021-07-01 10:21:17 帮助过:9人阅读
配置文件 jdbc.properties
jdbc.driver=com.mysql.jdbc.Driver jdbc.user=root jdbc.password=root jdbc.className=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/bookstore
加载配置文件:properties对象
开发中会使用Properties对象进行, 我们可以采用加载properties 文件获得流,然后使用Properties对象进行处理
1. 加载properties文件获取inputStream
1.1 方式1.使用类加载ClassLoader加载src的资源(固定写法) 获得ClassLoader固定写法:当前类.class.getClassLoader();
InputStream is= jdbcUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");
1.2 方式2 加载当前类同包下的资源,如果需要从src开始必须填写 ‘’/‘’
InputStream is2=jdbcUtil.class.getResourceAsStream("jdbc2.properties");
加载src下的资源
InputStream is3=jdbcUtil.class.getResourceAsStream("/jdbc.properties");
加载完成后:使用Properties处理流
Properties props=new Properties();
使用load() 方法加载指定的流
props.load(is); / props.load(is3); / props.load(is2);
Properties props=new Properties(); props.load(is); //使用getProperty(key),获取需要的值 className=props.getProperty("jdbc.className"); url=props.getProperty("jdbc.url"); user=props.getProperty("jdbc.user"); password=props.getProperty("jdbc.password");
jdbc加载项目
package com.jdec.util_v3; import java.io.IOException; import java.io.InputStream; import java.net.URL; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; public class jdbcUtil { private static String user; public static String password; public static String className; public static String url; Connection con=null; PreparedStatement pstm=null; ResultSet rs=null; static{ //1.加载properties文件获取inputStream /*1.1 方式1.使用类加载ClassLoader加载src的资源(固定写法) * 获得ClassLoader固定写法:当前类.class.getClassLoader(); */ InputStream is= jdbcUtil.class.getClassLoader().getResourceAsStream("jdbc.properties"); //加载当前类同包下的资源,如果需要从src开始必须填写/ InputStream is2=jdbcUtil.class.getResourceAsStream("jdbc2.properties"); //加载src下的资源 InputStream is3=jdbcUtil.class.getResourceAsStream("/jdbc.properties"); //使用Properties处理流 // 使用load() 方法加载指定的流 Properties props=new Properties(); try { props.load(is); //使用getProperty(key),获取需要的值 className=props.getProperty("jdbc.className"); url=props.getProperty("jdbc.url"); user=props.getProperty("jdbc.user"); password=props.getProperty("jdbc.password"); } catch (IOException e) { e.printStackTrace(); } } public jdbcUtil() { try{ Class.forName(className); } catch (ClassNotFoundException e) { e.printStackTrace(); } } public Connection getConnection() { try { con=(Connection) DriverManager.getConnection(url, user, password); } catch (SQLException e) { con=null; e.printStackTrace(); } return con; } public ResultSet excuteQuery(String sql, Object[] obj) { if (sql!=null ){ con=getConnection(); if(con!=null){ try { pstm=(PreparedStatement) con.prepareStatement(sql); if (obj!=null) { for(int i=0;i<obj.length;i++){ pstm.setObject(i+1,obj[i]); } } rs=pstm.executeQuery(); } catch (SQLException e) { e.printStackTrace(); } } } return rs; } public int excuteUpdate(String sql, Object[] obj) { // TODO Auto-generated method stub int flag=-1; if(sql!=null && obj!=null){ con=getConnection(); if (con!=null) { try { pstm=(PreparedStatement) con.prepareStatement(sql); for(int i=0;i<obj.length;i++){ pstm.setObject(i+1, obj[i]); } flag=pstm.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } } } return flag; } public ResultSet queryAll(String sql) { con=getConnection(); if(con!=null){ try { pstm=(PreparedStatement) con.prepareStatement(sql); rs=pstm.executeQuery(); } catch (SQLException e) { e.printStackTrace(); } } return rs; } public void closeAll() { // TODO Auto-generated method stub if (rs!=null) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (pstm!=null) { try { pstm.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (con!=null) { try { con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }
测试类
package com.jdbc.util; import java.sql.ResultSet; import java.sql.SQLException; import org.junit.Test; import com.jdbc.dao.JdbcUtils; import com.jdec.util_v3.jdbcUtil; public static void main(String[] args) throws SQLException{ jdbcUtil jd=new jdbcUtil(); String sql="select * from book"; Object[] obj=null; ResultSet rs=jd.excuteQuery(sql, obj); while(rs.next()){ System.out.println(rs.getObject("bookId")+" "+rs.getObject("bookName")+" "+rs.getObject("bookAuthor")); } } }
jdbc.properties
jdbc.user=root jdbc.password=root jdbc.className=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/bookstore
JavaWeb中jdbcproperties配置文件
标签:block 开始 需要 cti inpu exception rac source pre