发布时间：2026-07-21阅读(1)
java jdbc数据库连接
Java code
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129 | importjava.io.InputStream;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;importjava.util.Properties;publicclassJDBConnection {publicConnection conn = null; // 声明Connection对象的实例publicStatement stmt = null; // 声明Statement对象的实例publicResultSet rs = null; // 声明ResultSet对象的实例privatestaticString dbClassName = "com.microsoft.jdbc.sqlserver.SQLServerDriver";//定义保存数据库驱动的变量privatestaticString dbUrl = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=DB_ATM";privatestaticString dbUser = "sa";privatestaticString dbPwd = "sa";publicJDBConnection(String propertyFileName) {// 带属性文件名的构造方法Properties prop = newProperties();// 属性集合对象InputStream is = null;try{is = JDBConnection.class.getClassLoader().getResourceAsStream(propertyFileName);// 属性文件输入流// is = new FileInputStream("src/" propertyFileName);prop.load(is);// 将属性文件流装载到Properties对象中is.close();// 关闭流dbClassName = prop.getProperty("dbClassName");dbUrl = prop.getProperty("dbUrl");dbUser = prop.getProperty("dbUser");dbPwd = prop.getProperty("dbPwd");} catch(Exception e) {System.out.println("属性文件 " propertyFileName " 打开失败！");}try{Class.forName(dbClassName);// 1.注册驱动} catch(ClassNotFoundException e) {e.printStackTrace();}}publicJDBConnection() {// 默认的不带参数的构造函数try{Class.forName(dbClassName);// 1.注册驱动} catch(ClassNotFoundException e) {e.printStackTrace();}}publicstaticConnection getConnection() {Connection conn = null;try{// Class.forName(dbClassName);// 1.注册驱动conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd);//2.建立与数据库的链接} catch(Exception ee) {ee.printStackTrace();}if(conn == null) {System.err.println("警告: DbConnectionManager.getConnection() 获得数据库链接失败.\r\n\r\n链接类型:" dbClassName"\r\n链接位置:" dbUrl"\r\n用户/密码" dbUser "/" dbPwd);}returnconn;}/** 功能：执行查询语句*/public ResultSet executeQuery(String sql) {try { // 捕捉异常conn = getConnection(); // 调用getConnection()方法构造Connection对象的一个实例connstmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,//3.创建语句ResultSet.CONCUR_READ_ONLY);rs = stmt.executeQuery(sql);//4.执行查询} catch (SQLException ex) {System.err.println(ex.getMessage()); // 输出异常信息}return rs; // 返回结果集对象 5.结果处理}/** 功能:执行更新操作*/public int executeUpdate(String sql) {int result = 0; // 定义保存返回值的变量try { // 捕捉异常conn = getConnection(); // 调用getConnection()方法构造Connection对象的一个实例connstmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);result = stmt.executeUpdate(sql); // 执行更新操作} catch (SQLException ex) {result = 0; // 将保存返回值的变量赋值为0}return result; // 返回保存返回值的变量}/** 功能:关闭数据库的连接*/publicvoidclose() {//6.释放资源try{ // 捕捉异常try{if(rs != null) { // 当ResultSet对象的实例rs不为空时rs.close(); // 关闭ResultSet对象}} finally{try{if(stmt != null) { // 当Statement对象的实例stmt不为空时stmt.close(); // 关闭Statement对象}} finally{if(conn != null) { // 当Connection对象的实例conn不为空时conn.close(); // 关闭Connection对象}}}} catch(Exception e) {e.printStackTrace(System.err); // 输出异常信息}}} |
如您还有不明白的可以在下面与我留言或是与我探讨QQ群308855039，我们一起飞！
Copyright © 2024 有趣生活 All Rights Reserve吉ICP备19000289号-5 TXT地图HTML地图XML地图
