Java Web 主要代码
//注册action
package com.action;
import com.opensymphony.xwork2.ActionSupport;
import com.action.DBUtil;
import com.bean.*;
import java.sql.*;
public class RegisterAction extends ActionSupport {
private User user=new User();
public User getUser() {
return user;
}
public void setUser(User user) {
https://www.wendangku.net/doc/343754938.html,er = user;
}
@Override
public String execute() throws Exception {
// TODO Auto-generated method stub
int i=0;
Connection conn=DBUtil.getConnection();
String sql="insert into user values('"+user.getUsername()+"','"+user.getPassword()+"',
'"+user.getSex()+"','"+user.getEmail()+"','"+user.getSignature()+"','1')";
i=DBUtil.excuteSql(sql, conn);
DBUtil.close(conn);
if(i>0)
{
return SUCCESS;
}else
return INPUT;
}
}
//登录action
package com.action;
import java.io.*;
import java.security.Principal;
import java.sql.*;
import java.util.Enumeration;
import java.util.Locale;
import java.util.Map;
import javax.servlet.RequestDispatcher;
import javax.servlet.ServletInputStream;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import org.apache.struts2.ServletActionContext;
import org.apache.struts2.jasper.tagplugins.jstl.core.Out;
import com.error.*;
import https://www.wendangku.net/doc/343754938.html,er;
import com.opensymphony.xwork2.ActionSupport;
public class LoginAction extends ActionSupport{
private User user=new User();
private fieldError fe = new fieldError();
public User getUser() {
return user;
}
public void setUser(User user) {
https://www.wendangku.net/doc/343754938.html,er = user;
}
public fieldError getFe() {
return fe;
}
public void setFe(fieldError fe) {
this.fe = fe;
}
@Override
public String execute() throws Exception {
// TODO Auto-generated method stub
Connection conn=DBUtil.getConnection();
ResultSet rs = DBUtil.getResultSet("select * from user where username = '"+ user.getUsername()+ "' and grade=1", conn);
if(rs.next())
{
//System.out.println(rs.getString(3));
if(rs.getString(2).equals(user.getPassword()))
{
HttpServletRequest request=ServletActionContext.getRequest();
String name="name";
String password="password";
HttpSession session=request.getSession();
session.setAttribute(name, user.getUsername());
session.setAttribute(password, user.getPassword());
//System.out.println("weweew");
DBUtil.close(conn);
return SUCCESS;
}
else
{
fe.setLoginerror("用户密码错误，请重新输入！");
DBUtil.close(conn);
return INPUT;
}
}
else
{
fe.setLoginerror("用户不存在，请您注册！");
DBUtil.close(conn);
return "INPUT1";
}
}
}
//管理员登录action
package com.action;
import java.sql.Connection;
import java.sql.ResultSet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import org.ap
ache.struts2.ServletActionContext;
import com.bean.*;
import com.opensymphony.xwork2.ActionSupport;
import com.error.*;
public class AdminLoginAction extends ActionSupport {
private User user=new User();
private fieldError fe = new fieldError();
public User getUser() {
return user;
}
public void setUser(User user) {
https://www.wendangku.net/doc/343754938.html,er = user;
}
public fieldError getFe() {
return fe;
}
public void setFe(fieldError fe) {
this.fe = fe;
}
@Override
public String execute() throws Exception {
// TODO Auto-generated method stub
Connection conn=DBUtil.getConnection();
ResultSet rs = DBUtil.getResultSet("select * from user where username = '"+ user.getUsername()+ "'and grade='0'", conn);
if(rs.next())
{
if(rs.getString(2).equals(user.getPassword()))
{
HttpServletRequest request=ServletActionContext.getRequest();
String name="name";
String password="password";
HttpSession session=request.getSession();
session.setAttribute(name, user.getUsername());
session.setAttribute(password, user.getPassword());
DBUtil.close(conn);
return SUCCESS;
}
else
{
fe.setLoginerror("管理员密码错误，请重新输入！");
DBUtil.close(conn);
return INPUT;
}
}
else
{
fe.setLoginerror("管理员不存在！");
DBUtil.close(conn);
return "INPUT1";
}
}
}
//发布话题action
package com.action;
import java.sql.Connection;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import org.omg.CORBA.Request;
import com.opensymphony.xwork2.ActionSupport;
import com.bean.*;
public class AnnounceAction extends ActionSupport {
private Topic topic=new Topic();
public Topic getTopic() {
return topic;
}
public void setTopic(Topic topic) {
this.topic = topic;
}
public String execute() throws Exception {
// TODO Auto-generated method stub
int i=0;
Connection conn=DBUtil.getConnection();
String sql="insert into topic(title,content,author,submittime,forumid)values('"+topic.getTitle()+"','"+topic.getContent()+"','"+topic.getAuthor() +"'
," +"'"+ new SimpleDateFormat("yyyy-MM-dd").format(Calendar.getInstance().getTime())+"','"+topic.getForumid()+"')";
i=DBUtil.excuteSql(sql, conn);
DBUtil.close(conn);
if(i>0)
{
return SUCCESS;
}else
return INPUT;
}
}
//回复action
package com.action;
import java.sql.Connection;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import javax.servlet.http.HttpServletRequest;
import com.bean.Topic;
import com.bean.TopicRes;
import com.opensymphony.xwork2.ActionSupport;
public class AnnounceResponseAction extends ActionSupport {
private TopicRes topicre=new TopicRes();
private Topic topic =new Topic();
public TopicRes getTopicre() {
return topicre;
}
public void setTopicre(TopicRes topicre) {
this.topicre = topi
cre;
}
public Topic getTopic() {
return topic;
}
public void setTopic(Topic topic) {
this.topic = topic;
}
public String execute() throws Exception {
// TODO Auto-generated method stub
Connection conn=DBUtil.getConnection();
String titletemp=topic.getTitle();
int tempid=topicre.getId();
try{ResultSet rs=DBUtil.getResultSet("select title from topic where id='"+topicre.getId()+"'", conn);
if(rs.next())
titletemp=rs.getString(1);}catch(Exception e){e.getMessage();}
System.out.println(titletemp);
System.out.println(tempid);
int i=0;
String sql="insert into response(title,content,author,submittime,topicid)values('"+titletemp+"'
,'"+topicre.getContent()+"','"+topicre.getAuthor()+"',
'"+ new SimpleDateFormat("yyyy-MM-dd").format(Calendar.getInstance().getTime())+"','"+topicre.getId()+"')";
i=DBUtil.excuteSql(sql, conn);
DBUtil.close(conn);
if(i>0)
{
return SUCCESS;
}else
System.out.println("dsafsafsafsafsa");
return INPUT;
}
}
//显示话题action
package com.action;
import java.util.List;
import com.action.*;
import com.bean.*;
import com.opensymphony.xwork2.ActionSupport;
public class ShowTopicList extends ActionSupport {
private List
private int pageNow = 1 ; //初始化为1,默认从第一页开始显示
private int pageSize = 10 ; //每页显示10条记录
private TopicList topiclist = new TopicList();
public List
return topic;
}
public void setTopic(List
this.topic = topic;
}
public int getPageNow() {
return pageNow;
}
public void setPageNow(int pageNow) {
this.pageNow = pageNow;
}
public int getPageSize() {
return pageSize;
}
public void setPageSize(int pageSize) {
this.pageSize = pageSize;
}
public TopicList getTopiclist() {
return topiclist;
}
public void setTopiclist(TopicList topiclist) {
this.topiclist = topiclist;
}
@Override
public String execute() throws Exception {
// TODO Auto-generated method stub
topiclist.getI();
//topiclist.setJ(this.getPageNow());
topiclist.getJ();
topic = topiclist.topicbypage(pageSize, pageNow);
return SUCCESS;
}
}
//删除action
package com.action;
import java.sql.Connection;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import https://www.wendangku.net/doc/343754938.html,er;
public class DeleteAction {
private User user1;
public User getUser1() {
return user1;
}
public void setUser1(User user1) {
https://www.wendangku.net/doc/343754938.html,er1 = user1;
}
public boolean deleteuser(String username) {
Boolean success =false;
int i=0;
Connection conn=DBUtil.getConnection();
String sql="delete from user where username='"+username+"'";
i=DBUtil.excuteSql(sql, conn);
DBUtil.close(conn);
if(i>0)
{
success=true;
}
return success;
}
}
//修改密码action
package com.action;
import com.opensymphony.xwork2.ActionContext;
import com.op
ensymphony.xwork2.ActionSupport;
import com.action.*;
import java.sql.*;
public class upassAction extends ActionSupport{
private String upassword;
public String getUpassword() {
return upassword;
}
public void setUpassword(String upassword) {
this.upassword = upassword;
}
public Boolean Upass(){
if(this.getUpassword().isEmpty()||this.getUpassword().contains("，")||!this.getUpassword().contains(",")){
this.addFieldError("er", "修改内容不能为空,且新旧密码只能用英文逗号分隔!");
return false;
}
else
{
ActionContext ac=ActionContext.getContext();
String s1=(String)(ac.getSession().get("name"));//取得页面的用户名称
String sups=(String)(ac.getSession().get("password"));//取得页面的用户密码
String[] sourceStrArray=this.getUpassword().split(",");
if(sourceStrArray.length>2)
{
this.addFieldError("t", "新旧密码必须用逗号分开，且新密码中不能包含,");
return false;
}
else
{
if(!sourceStrArray[0].equals(sups))
{
this.addFieldError("t1", "旧密码有误请核实后重新输入!");
return false;
}
else{
if(sourceStrArray[1].isEmpty()){
this.addFieldError("t2", "新密码不能为空!");
return false;
}
else{
String sql2="update user set password='"+sourceStrArray[1]+"' where username='"+s1+"'";
try{
Connection con1=DBUtil.getConnection();
int x=DBUtil.excuteSql(sql2,con1);
if(x<0){
System.out.println("更新失败");
return false;
}
else
return true;
}
catch(Exception e){
System.out.println("数据操作有误");
return false;
}
}
}
}
}
}
@Override
public String execute() throws Exception {
// TODO Auto-generated method stub
if(!Upass()){
return INPUT;
}
else{
return SUCCESS;
}
}
}
//修改用户信息action
package com.action;
import java.sql.Connection;
import com.opensymphony.xwork2.ActionContext;
import com.opensymphony.xwork2.ActionSupport;
import com.bean.*;
public class UpdateUserAction extends ActionSupport {
private User user;
public User getUser() {
return user;
}
public void setUser(User user) {
https://www.wendangku.net/doc/343754938.html,er = user;
}
public String execute() throws Exception {
// TODO Auto-generated method stub
ActionContext ac=ActionContext.getContext();
String s1=(String)(ac.getSession().get("name"));//取得页面的用户名称
int i=0;
Connection conn=DBUtil.getConnection();
String sql="update user set username='"+user.getUsername()+"',sex='"+user.getSex()+"',
email='"+user.getEmail()+"',signature='"+user.getSignature()+"' where username='"+s1+"'";
i=DBUtil.excuteSql(sql, conn);
DBUtil.close(conn);
if(i>0)
{
return SUCCESS;
}else
return INPUT;
}
}