javaWeb购物商城设计---数据库连接

水深无声 2022-06-04 01:08 326阅读 0赞

数据库采用的是sql server数据库，连接数据库用到的方法写进一个类connDB当中(类放在com.tools当中)，每次需要访问数据库时，实例化这个类，并调用它封装的方法。数据库是已经在sql server创建好的db_shop
成员变量：

  1. public Connection conn = null; // 数据库连接对象
  2.     public Statement stmt = null; // statement对象，用于执行Sql语句
  3.     public ResultSet rs = null; // 结果对象集
  4.     // 驱动类的类名
  5.     private static String dbClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
  6.     private static String dbUrl = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=db_shop";
  7.     private static String dbUser = "sa"; // 登录sql的用户名
  8.     private static String dbPwd = "****"; // 登录sql的密码

创建连接

  1. /*
  2.      * 创建与数据库的连接
  3.      */
  4.     public static Connection getConnection() {
  5.         Connection conn = null;
  6.         try {
  7.             Class.forName(dbClassName).newInstance(); // 装在数据库驱动
  8.             // 获取数据库连接对象
  9.             conn = DriverManager.getConnection(dbUrl, dbUser, dbPwd);
  10.         } catch (Exception e) {
  11.             e.printStackTrace();
  12.         }
  13.         if (conn == null) {
  14.             System.err.println("DbConnectionManger.getConnection():" + dbClassName + "\r\n" + dbUrl + "\r\n" + dbUser
  15.                     + "/" + dbPwd);
  16.         } else {
  17.             System.out.println("数据库连接成功");
  18.         }
  19.         return conn;
  20.     }

更新数据

  1. /*
  2.      * 更新数据功能
  3.      */
  4.     public int executeUpdate(String sql) {
  5.         int result = 0; // 更新数据的记录条数
  6.         try {
  7.             conn = getConnection(); // 获取数据库连接
  8.             // 创建用于执行SQL语句的statement对象
  9.             stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
  10.             result = stmt.executeUpdate(sql);
  11.         } catch (SQLException e) {
  12.             // TODO: handle exception
  13.             result = 0;
  14.             e.printStackTrace(); // 输出异常信息
  15.         }
  16.         try {
  17.             stmt.close();
  18.         } catch (SQLException e) {
  19.             // TODO: handle exception
  20.             e.printStackTrace();
  21.         }
  22.         return result;
  23.     }

查询数据

  1. /*
  2.      * 根据指定的sql语句查询数据
  3.      */
  4.     public ResultSet executeQuery(String sql) {
  5.         try {
  6.             conn = getConnection(); // 获取数据库连接
  7.             // 创建用于执行SQL语句的statement对象
  8.             stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
  9.             rs = stmt.executeQuery(sql); // 执行SQL语句
  10.         } catch (SQLException e) {
  11.             // TODO: handle exception
  12.             e.printStackTrace();
  13.         }
  14.         return rs;
  15.     }

关闭数据库连接

  1. /*
  2.      * 关闭数据库
  3.      */
  4.     public void close() {
  5.         try {
  6.             if (rs != null) {
  7.                 rs.close();
  8.             }
  9.             if (stmt != null) {
  10.                 stmt.close();
  11.             }
  12.             if (conn != null) {
  13.                 conn.close();
  14.             }
  15.         } catch (Exception e) {
  16.             // TODO: handle exception
  17.             e.printStackTrace(System.err);
  18.         }
  19.     }

测试一下

写好之后，需要将sql server的jdbc连接jar包导入，这里用到sqljdbc42.jar，然后写一个junit测试方法单独试一下

  1. @Test
  2.     public void test() {
  3.         if (getConnection() != null) {
  4.             System.out.println("测试连接成功");
  5.         }
  6.     }

发表评论

表情：
评论列表 （有 0 条评论，326人围观）

还没有评论，来说两句吧...

相关阅读

    相关 网上购物商城系统设计与实现

    > 项目背景和意义 目的：伴随着互联网技术的不断发展和完善，在人们的生活和工作的各个方面，互联网都有着非常重大的影响。伴随着国内电子商务行业的迅猛发展，消费者现在能够轻松

    小咪咪小咪咪/ 0 赞/ 189 阅读