网络留言系统（Javaweb简易开发）

第一步：建立数据库test

第二步：创建javaee项目，onlineMessage

第三步：创建JDBC

先导入JDBC驱动包

创建SqlSrvDBConn类

第四步：构件JavaBean

第五步：编写Servlet

MainServlet

AddServlet

RegisterServlet

第六步：编写页面

main.jsp

liuyan.jsp

error.jsp

第七步：配置文件

界面运行效果如下：

项目源代码：

问题整理：

采用JSP+Servlet+JavaBean+JDBC方式开发一个网络留言系统。

要求：（1）用户在页面上输入用户名和密码登录，成功进入后可以看到所有的留言信息（2）用户可以自己添加，编辑留言，提交后可实时看到新增加的留言（3）系统提供新用户注册的功能

第一步：建立数据库test

我用的是mysql数据库，数据库中有两张表，用户信息表usertable和留言表lytable

表结构如下：

第二步：创建javaee项目，onlineMessage

第三步：创建JDBC

先导入JDBC驱动包

创建SqlSrvDBConn类

这个类主要就是连接数据库，操作数据库的。

public class SqlSrvDBConn {private Statement stmt;private Connection conn;ResultSet rs;//在构造方法中创建数据库连接public SqlSrvDBConn(){stmt=null;try {//1.加载并注册驱动Class.forName("com.mysql.jdbc.Driver");//2.获取数据库连接对象Connection conn= DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","root");} catch (Exception e) {e.printStackTrace();}rs=null;}//获取数据库连接public Connection getConn(){return this.conn;}//执行查询类的SQL语句，有返回集public ResultSet executeQuery(String sql){try {//5.获取执行sql对象Statementstmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);//6.执行sqlrs=stmt.executeQuery(sql);} catch (SQLException throwables) {throwables.printStackTrace();}return rs;}//关闭对象public void closeStmt(){try {//8.释放资源stmt.close();} catch (SQLException e) {System.err.println("Data.executeQuery: " + e.getMessage());}}public void closeConn(){try {//8.释放资源conn.close();} catch (SQLException e) {System.err.println("Data.executeQuery: " + e.getMessage());}}}

第四步：构件JavaBean

底层数据库有几个表，就创建几个JavaBean，其实就是Java实体。里边写属性和get和set方法

public class UserTable {//属性private Integer id;private String username;private String password;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}
}

public class LyTable implements java.io.Serializable {//属性private Integer id;private Integer userId;private Date date;private String title;private String content;public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public Integer getUserId() {return userId;}public void setUserId(Integer userId) {this.userId = userId;}public Date getDate() {return date;}public void setDate(Date date) {this.date = date;}public String getTitle() {return title;}public void setTitle(String title) {this.title = title;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}
}

第五步：编写Servlet

MainServlet

MainServlet：主要实现登录验证功能和对留言的查询功能，查询所有的留言信息。

@WebServlet("/mainServlet")
public class MainServlet extends HttpServlet {protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//设置请求编码request.setCharacterEncoding("gb2312");//获取提交的用户名String usr = request.getParameter("username");//获取提交的密码String pwd = request.getParameter("password");//定义一个变量作为验证成功与否的标识boolean validated=false;//与数据库有关SqlSrvDBConn sqlsrvdb=new SqlSrvDBConn();//获得会话对象，用来存储当前登录的用户信息HttpSession session=request.getSession();//创建一个user对象，并设置为空UserTable user=null;//先获得UserTable对象，如果是第一次访问该页，用户对象肯定为空，但如果是第二次甚至是第三次，就直接登录主页而无须再次重复验证该用户的信息user=(UserTable)session.getAttribute("user");//如果是第一次进入if(user==null){//查询usertable表中的记录String sql="select * from usertable";//取得结果集ResultSet rs=sqlsrvdb.executeQuery(sql);try{while(rs.next()){//如果用户名和密码都正确if((rs.getString("username").trim().compareTo(usr)==0)&&(rs.getString("password").compareTo(pwd)==0)){user=new UserTable();               //创建持久化的JavaBean对象useruser.setId(rs.getInt(1));user.setUsername(rs.getString(2));user.setPassword(rs.getString(3));session.setAttribute("user", user);    //把user对象存储在会话中validated=true;                     //标识为true表示验证成功通过}}rs.close();}catch (SQLException e){e.printStackTrace();}sqlsrvdb.closeStmt();}else{validated=true;//该用户在之前已经注册登录过了，已经验证过身份了，无需再验证}//身份验证之后---------------------------------------if(validated){//验证成功，应该去主界面，主界面显示留言的所有信息，所以要从留言表中查出来，并且暂存在会话中ArrayList al=new ArrayList();try{String sql="select * from lyTable";ResultSet rs=sqlsrvdb.executeQuery(sql);   //取得结果集while(rs.next()){LyTable ly=new LyTable();ly.setId(rs.getInt(1));ly.setUserId(rs.getInt(2));ly.setDate(rs.getDate(3));ly.setTitle(rs.getString(4));ly.setContent(rs.getString(5));al.add(ly);}rs.close();}catch(SQLException e){e.printStackTrace();}sqlsrvdb.closeStmt();session.setAttribute("al", al);//然后跳转到main.jspresponse.sendRedirect("main.jsp");}else{//验证失败跳转到error.jspresponse.sendRedirect("error.jsp");}}protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request,response);}
}

AddServlet

AddServlet：这个主要实现留言的添加功能，要在会话中保存一份，也要在数据库中存储留言信息

@WebServlet("/addServlet")
public class AddServlet extends HttpServlet {protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {request.setCharacterEncoding("gb2312");String title = request.getParameter("title");String content = request.getParameter("content");HttpSession session = request.getSession();//从会话中获取出当前用户的对象UserTable user = (UserTable)session.getAttribute("user");//建立留言表对应的JavaBean对象，把数据封装进去LyTable ly=new LyTable();ly.setUserId(user.getId());                            //获取当前登录用户的idly.setDate(new Date(System.currentTimeMillis()));  //获取当前系统时间ly.setTitle(title);ly.setContent(content);ArrayList al=(ArrayList)session.getAttribute("al");al.add(ly);//向数据库中插入新的留言记录PreparedStatement pstmt=null;SqlSrvDBConn sqlsrvdb=new SqlSrvDBConn();Connection ct=sqlsrvdb.getConn();try{pstmt=ct.prepareStatement("insert into lyTable(userid,date,title,content) values(?,?,?,?)");pstmt.setInt(1, ly.getUserId());pstmt.setDate(2, (Date) ly.getDate());pstmt.setString(3, ly.getTitle());pstmt.setString(4, ly.getContent());pstmt.executeUpdate();response.sendRedirect("main.jsp");}catch(SQLException e){e.printStackTrace();response.sendRedirect("liuyan.jsp");}}protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request,response);}
}

RegisterServlet

RegisterServlet主要实现新用户的注册，将信息存入数据库

@WebServlet("/registerServlet")
public class RegisterServlet extends HttpServlet {protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {request.setCharacterEncoding("gb2312");String usr = request.getParameter("username");String pwd = request.getParameter("password");//向数据库中插入用户名和密码PreparedStatement pstmt=null;SqlSrvDBConn sqlsrvdb=new SqlSrvDBConn();Connection ct=sqlsrvdb.getConn();try{pstmt=ct.prepareStatement("insert into usertable(username,password) values(?,?)");pstmt.setString(1, usr);pstmt.setString(2, pwd);pstmt.executeUpdate();response.sendRedirect("login.jsp");}catch(SQLException e){e.printStackTrace();}}protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request,response);}
}

第六步：编写页面

login.jsp

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head><title>简易留言板</title>
</head>
<body bgcolor="#E3E3E3">
<form action="mainServlet" method="post"><table><caption>用户登录</caption><tr><td>用户名：</td><td><input type="text" name="username" size="20"/></td></tr><tr><td>密码:</td><td><input type="password" name="password" size="21"/></td></tr></table><input type="submit" value="登录"/><input type="reset" value="重置"/>
</form>
如果没注册单击<a href="register.jsp">这里</a>注册！
</body>
</html>

register.jsp

<%@ page language="java" pageEncoding="gb2312"%>
<html>
<head><title>简易留言板</title>
</head>
<body bgcolor="#E3E3E3"><form action="registerServlet" method="post"><table><caption>用户注册</caption><tr><td>登录名：</td><td><input type="text" name="username"/></td></tr><tr><td>密码:</td><td><input type="password" name="password"/></td></tr></table><input type="submit" value="注册"/><input type="reset" value="重置"/></form>
</body>
</html>