Java-JDBCUtil工具类

import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; import org.apache.log4j.Logger; public class JdbcUtil { public static Logger logger = Logger.getLogger(JdbcUtil.class.getName()); // 创建静态全局变量 // static Connection conn; // static Statement statement; public static Connection getConnection() { String jdbc_url = null; //String jdbc_db = null; String jdbc_driver = null; String jdbc_name = null; String jdbc_password = null; try { Properties prop = new Properties(); // InputStream inStream = // JdbcUtil.class.getResourceAsStream("config/database.properties"); InputStream inStream = new FileInputStream(new File("config/database.properties")); prop.load(inStream); jdbc_url = prop.getProperty("jdbc_url"); //jdbc_db = prop.getProperty("jdbc_db"); jdbc_driver = prop.getProperty("jdbc_driver"); jdbc_name = prop.getProperty("jdbc_name"); jdbc_password = prop.getProperty("jdbc_password"); } catch (FileNotFoundException e1) { e1.printStackTrace(); } catch (IOException e1) { e1.printStackTrace(); } Connection con = null; // 创建用于连接数据库的Connection对象 try { Class.forName(jdbc_driver);// 加载Mysql数据驱动 // con = DriverManager.getConnection(jdbc_url + jdbc_db, jdbc_name, // jdbc_password);// 创建数据连接 con = DriverManager.getConnection(jdbc_url + "?user=" + jdbc_name + "&password=" + jdbc_password + "&useUnicode=true&characterEncoding=utf-8");// 创建数据连接 } catch (Exception e) { System.out.println("数据库连接失败" + e.getMessage()); } return con; // 返回所建立的数据库连接 } /* 插入数据记录，并输出插入的数据记录数 */ public static void insert(String sql) { Connection conn = getConnection(); // 首先要获取连接，即连接到数据库 try { logger.info("jdbc插入数据开始"); Statement statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象 int count = statement.executeUpdate(sql); // 执行插入操作的sql语句，并返回插入数据的个数 System.out.println("更新 " + count + " 条数据"); // 输出插入操作的处理结果 statement.close(); conn.close(); // 关闭数据库连接 logger.info("jdbc插入数据结束"); } catch (SQLException e) { System.out.println("插入数据失败" + e.getMessage()); } } /* 更新符合要求的记录，并返回更新的记录数目 */ public static void update(String sql) { Connection conn = getConnection(); // 同样先要获取连接，即连接到数据库 try { // logger.info("jdbc更新数据开始"); // String sql = // "update staff set wage='2200' where name = 'lucy'";// 更新数据的sql语句 Statement statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象，st属局部变量 int count = statement.executeUpdate(sql);// 执行更新操作的sql语句，返回更新数据的个数 System.out.println("更新 " + count + " 条数据"); // 输出更新操作的处理结果 statement.close(); conn.close(); // 关闭数据库连接 // logger.info("jdbc更新数据结束"); } catch (SQLException e) { System.out.println("更新数据失败"); } } /* 查询数据库，输出符合要求的记录的情况 */ public static String query(String sql,String queryContent) { Connection conn = getConnection(); // 同样先要获取连接，即连接到数据库 String queryContentTemp = ""; try { Statement statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象，st属局部变量 ResultSet rs = statement.executeQuery(sql); // 执行sql查询语句，返回查询数据的结果集 while (rs.next()) { // 判断是否还有下一个数据 // 根据字段名获取相应的值 queryContentTemp = rs.getString(queryContent); } rs.close(); statement.close(); conn.close(); // 关闭数据库连接 } catch (SQLException e) { e.printStackTrace(); } return queryContentTemp; } /* 删除符合要求的记录，输出情况 */ public static void delete(String sql) { Connection conn = getConnection(); // 同样先要获取连接，即连接到数据库 try { logger.info("jdbc删除数据开始"); // String sql = "delete from staff where name = 'lili'";// // 删除数据的sql语句 Statement statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象，st属局部变量 int count = statement.executeUpdate(sql);// 执行sql删除语句，返回删除数据的数量 System.out.println("agent表中删除了【 " + count + " 】条数据。"); // 输出删除操作的处理结果 statement.close(); conn.close(); // 关闭数据库连接 logger.info("jdbc删除数据结束"); } catch (SQLException e) { System.out.println("删除数据失败"); } } }

转载于:https://www.cnblogs.com/bilaisheng/p/10211020.html

相关资源：java高效开发小工具-jdbcutil2