码迷,mamicode.com
首页 > 数据库 > 详细

JavaWeb之原生数据库连接

时间:2017-12-26 14:23:50      阅读:217      评论:0      收藏:0      [点我收藏+]

标签:mysq   connect   用户名   where   throw   mapping   prot   连接池   out   

我们在开发JavaWeb项目时,常会需要连接数据库。我们以MySQL数据库为例,IDE工具为eclipse,讲述数据库连接与基本操作。

第一步,我们在我们在Web项目的WebContent中简单建一个前端页面login.html,内容如下:  

<!DOCTYPE html> 
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>登录页</title>
</head>
<body>
    <p>
        请登录
    </p>
    <form action="LoginServlet" method="post">
        <p><input type="text" placeholder="请输入用户名" name="username"> </p>
        <p><input type="password" placeholder="请输入密码" name="userpwd"> </p>
        <p><input type="submit" value="登录"> </p>
    </form>
</body>
</html>

接着,我们修改WebContent--->WEB-INF中的web.xml,对立面的配置做如下修改:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">
    <welcome-file-list>
        <welcome-file>login.html</welcome-file>
    </welcome-file-list>
    <servlet>
        <servlet-name>LoginServlet</servlet-name>
        <servlet-class>com.itszt.demo.LoginServlet</servlet-class>
    </servlet>
    <servlet-mapping>
        <servlet-name>LoginServlet</servlet-name>
        <url-pattern>/LoginServlet</url-pattern>
    </servlet-mapping>
</web-app> 

第二步,我们在Web项目的WebContent--->WEB-INF中看有无名称为lib的文件夹,若没有则建立一个名称为lib的文件夹,若有则使用该文件夹,然后将mysql驱动文件拷贝到lib文件夹里。同时,在Java Resources--->src中建立名称为db-config.properties的属性配置文件,改文件内容为:

db.DRIVER=com.mysql.jdbc.Driver
db.URL=jdbc:mysql://localhost:3306/itszt2
db.USERNAME=root
db.PASSWROD=2017 

 第三步,我们在Java Resources--->src中分别建立两个文件夹com.itszt.demo和com.itszt.utils,在com.itszt.demo文件夹中创建一个名称为LoginServlet.java的Servlet文件,用以接收与处理前端页面传来的数据;在com.itszt.utils里创建一个名称为Util_1_JDBC.java的工具类文件,用以处理数据库连接。

Util_1_JDBC.java文件内容如下:

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
import java.util.ResourceBundle;
/**
 * 连接数据库,以及释放资源
 */
public abstract class Util_1_JDBC {
    private static String DB_DRIVER=null;
    private static String DB_URL=null;
    private static String DB_USER=null;
    private static String DB_PASSWORD=null;
    //注册mysql驱动
    static {
    //也可以采用ResourceBundle来解析与读取属性文件里的配置信息;我们在此采用Properties类加载属性文件
//        ResourceBundle bundle = ResourceBundle.getBundle("db-config.properties");
//        String DB_DRIVER=bundle.getString("db.DRIVER");
//      ...
        Properties properties=new Properties();
        InputStream resourceAsStream = Util_1_JDBC.class.getClassLoader().getResourceAsStream("db-config.properties");
        try {
            properties.load(resourceAsStream);
            String DB_DRIVER = properties.getProperty("db.DRIVER");
            String DB_URL = properties.getProperty("db.URL");
            String DB_USER = properties.getProperty("db.USERNAME");
            String DB_PASSWORD = properties.getProperty("db.PASSWROD");
        } catch (IOException e) {
            throw new RuntimeException("读取属性文件失败!");
        }
        try {
            Class.forName(DB_DRIVER);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException("注册驱动失败!");
        }
    }
    /**
     * 打开与数据库的连接
     * @return 一个连接对象
     */
    public static Connection openConnection(){
        try {
            return DriverManager.getConnection(DB_URL,DB_USER,DB_PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
    //释放资源
    public static void release(Connection connection, Statement statement, ResultSet resultSet){
        if(connection!=null){
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (statement != null) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

 我们再来看LoginServlet.java的内容: 

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
@WebServlet(name = "LoginServlet")
public class LoginServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("UTF-8");
        String username = request.getParameter("username");
        System.out.println("username="+username);
        String userpwd = request.getParameter("userpwd");
        System.out.println("userpwd="+userpwd);
        PreparedStatement statement=null;
        ResultSet resultSet=null;
        //1.不采用数据源连接池,需要频繁建立与数据库的连接与释放资源
Connection connection = UtilJDBC.openConnection();
        try {
        statement=connection.prepareStatement("SELECT * FROM users where username=? AND  userpwd=?");
        statement.setString(1,username);
        statement.setString(2,userpwd);
        resultSet = statement.executeQuery();
        if(resultSet.next()){
            System.out.println("登录成功!");
        }else{
            System.out.println("登录失败!");
        }
    } catch (SQLException e) {
        e.printStackTrace();
    }finally {
        Util_1_JDBC.release(connection,statement,resultSet);
    }

      }  

     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { 
     doPost(request, response);
    }
}

 另外,数据库名称为itszt2,要访问的表users的结构为:

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(20) NOT NULL,
  `userpwd` varchar(20) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

该表中存了一条数据,即(“xiaoming”,123456)。

读者可以在自己的电脑上对上述代码进行测试,以观察数据库连接,以及练习sql语句的若干操作。   

JavaWeb之原生数据库连接

标签:mysq   connect   用户名   where   throw   mapping   prot   连接池   out   

原文地址:https://www.cnblogs.com/lizhangyong/p/8117321.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!