基于Struts2 的日志管理系统的Java实现

package com.sxl.dba;
import java.sql.*;
//设计模式1：单例模式
public class OracleConnector {
    private static Connection conn;
    public static Connection getOracleConn()
    {
        //java bean
        try
        {
            //判断是否有打开过连接，如果打开过则返回已有连接，
            //如果没有打开过则新建立连接
            if(conn==null)
            {
                Class.forName("oracle.jdbc.OracleDriver");
                  String url="jdbc:oracle:thin:@127.0.0.1:1521:orcl";
                  String user="system";
                  String pass="orcl1234";
              
                      //通过驱动管理器获取 oracle数据库连接
                  conn= DriverManager.getConnection(url, user, pass);
                System.out.println("数据库连接成功！");
            }
        }
        catch(Exception ex)
        {
            System.out.println("数据库连接失败:"+ex.getMessage());
        }
        
        return conn;
    }
}

package com.sxl.pojos;

import java.util.Date;

public class Log {    //对应数据库表名：log 
    private int lid; //日志ID
    private String title;  //日志标题
    private String content; //日志内容
    private int uid;  //用户ID，对应的数据库字段：userid
    private Date date; //日志日期，对应数据库字段：logdate
    
    public int getLid() {
        return lid;
    }
    public void setLid(int lid) {
        this.lid = lid;
    }
    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;
    }
    public int getUid() {
        return uid;
    }
    public void setUid(int uid) {
        this.uid = uid;
    }
    public Date getDate() {
        return date;
    }
    public void setDate(Date date) {
        this.date = date;
    }
    //构造函数
    public Log(int lid, String title, String content, int uid, Date date) {
        super();
        this.lid = lid;
        this.title = title;
        this.content = content;
        this.uid = uid;
        this.date = date;
    }
    public Log() {
        super();
        // TODO Auto-generated constructor stub
    }
    @Override
    public String toString() {
        return "Log [lid=" + lid + ", title=" + title + ", content=" + content
                + ", uid=" + uid + ", date=" + date + "]";
    }
       
}

package com.sxl.pojos;

public class User { //对应数据库表名为：loguser
    private int uid;  //用户ID，对应的数据库字段：userid
    private String name; //用户姓名
    private String pass; //用户密码
    
    public int getUid() {
        return uid;
    }
    public void setUid(int uid) {
        this.uid = uid;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getPass() {
        return pass;
    }
    public void setPass(String pass) {
        this.pass = pass;
    }
    
    public User(int uid, String name, String pass) {
        super();
        this.uid = uid;
        this.name = name;
        this.pass = pass;
    }
    public User() {
        super();
        // TODO Auto-generated constructor stub
    }
    @Override
    public String toString() {
        return "User [uid=" + uid + ", name=" + name + ", pass=" + pass + "]";
    }
}

package com.sxl.services;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.sxl.pojos.Log;


public class LogService {
    private Connection conn=null;

    public LogService() {
        conn=com.sxl.dba.OracleConnector.getOracleConn();
    }
    
    //根据日志ID查找
    public Log findByLid(int lid) {
        if (conn!=null) {
            try {
                Statement st=conn.createStatement();
                String sql="select * from log where lid=‘"+lid+"‘";
                ResultSet rs=st.executeQuery(sql);
                
                if (rs.next()) {
                    Log log=new Log();
                    log.setContent(rs.getString("content"));
                    log.setTitle(rs.getString("title"));
                    log.setLid(rs.getInt("lid"));
                    log.setUid(rs.getInt("uid"));
                    return log;
                }else {
                    System.out.println("连接出错，未查到！");
                }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        }
        return null;
    }
    
    //添加日志
    public boolean add(Log log) {
        try {
            Statement st=conn.createStatement();
            
            DateFormat format1=new SimpleDateFormat("yyyy-MM-dd");
            String date=format1.format(log.getDate());
            
            String sql="insert into log(title,content,userid,logdate) values(‘"+log.getTitle()+"‘,‘"+log.getContent()+"‘,‘"+log.getUid()+"‘,‘"+date+"‘)";
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }        
        return false;
    }
    
    //修改日志
    public boolean modify(Log log) {
        try {
            Statement st=conn.createStatement();
            Date nowDate=new Date();
            DateFormat format1=new SimpleDateFormat("yyyy-MM-dd");
            String date=format1.format(nowDate);
            String sql="update log set title=‘"+log.getTitle()+"‘,content=‘"+log.getContent()+"‘,logdate=‘"+date+"‘,where lid="+log.getLid();
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
    
    //根据用户ID查找
    public List<Log> findByUid(int uid) {
        List<Log> list=new ArrayList<Log>();
        if (conn!=null) {
            try {
                Statement st=conn.createStatement();
                System.out.println("进入查询...");
                String sql="select * from log where userid=‘"+uid+"‘";
                ResultSet rs=st.executeQuery(sql);
                while (rs.next()) {
                    System.out.println("查询结果为：");
                    Log log=new Log();
                    
                    log.setContent(rs.getString("content"));
                    log.setTitle(rs.getString("title"));
                    log.setLid(rs.getInt("lid"));
                    log.setUid(rs.getInt("uid"));
                    log.setDate(rs.getDate("date"));
                    
                    list.add(log);
                                    }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return list;
    }
    
    //删除日志
    public boolean del(int lid) {
        try {
            Statement st=conn.createStatement();
            String sql="delete from log where lid="+lid;
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
}

package com.sxl.services;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


import com.sxl.pojos.User;

public class UserService {
     private Connection conn=null;

    public UserService() {
        conn=com.sxl.dba.OracleConnector.getOracleConn();
    }
    
    //检查（查找）用户
    public int find(User user) {
        if (conn!=null) {
            try {
                Statement st=conn.createStatement();
                String sql="select userid from loguser where name=‘"+user.getName().replace(‘\‘‘, ‘ ‘)+"‘ and pass=‘"+user.getPass().replace(‘\‘‘, ‘ ‘)+"‘";
                ResultSet rs=st.executeQuery(sql);
                
                if (rs.next()) {
                    return rs.getInt("uid");
                }else {
                    System.out.println("对不起，该用户不存在");
                }                
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }            
        }    
        return -1;
    }
     
    //添加用户
    public boolean add(User user) {
        try {
            Statement st=conn.createStatement();
            String sql="insert into loguser values(‘"+user.getUid()+"‘,‘"+user.getName()+"‘,‘"+user.getPass()+"‘)";
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
    
    //修改用户
    public boolean modify(User user) {
        try {
            Statement st=conn.createStatement();
            String sql="update loguser set name=‘"+user.getName()+"‘,pass=‘"+user.getPass()+"‘ where userid="+user.getUid();
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return false;
    }
    
    //删除用户
    public boolean del(int uid) {
        try {
            Statement st=conn.createStatement();
            String sql="delete from loguser where userid="+uid;
            st.execute(sql);
            return true;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }        
        return false;
    }    
}

package com.sxl.actions;

import java.text.DateFormat;
import java.util.Date;

import javax.servlet.http.HttpServletRequest;

import org.apache.struts2.ServletActionContext;


import java.util.List;
import com.opensymphony.xwork2.ActionSupport;

import com.sxl.pojos.Log;
import com.sxl.services.LogService;

public class LogAction extends ActionSupport {
    private int uid;
    private int lid;
    private Log log;
    
    //提取出公共的部分
    private LogService logService=new LogService();
    HttpServletRequest request=ServletActionContext.getRequest();
    
    public int getUid() {
        return uid;
    }

    public void setUid(int uid) {
        this.uid = uid;
    }

    public int getLid() {
        return lid;
    }

    public void setLid(int lid) {
        this.lid = lid;
    }

    public Log getLog() {
        return log;
    }

    public void setLog(Log log) {
        this.log = log;
    }

    
    public String  add() throws Exception {
        log.setDate(new Date());
        if (logService.add(log)) {
            return "success";
        }else {
            return "failed";
        }            
    }
    
    
    public String getAllLog() throws Exception{
        List<Log> logList=logService.findByUid(uid);
        request.setAttribute("logList", logList);
        return "getAllLog";        
    }
    
    public String getByLid() throws Exception{
        Log log=logService.findByLid(lid);
        request.setAttribute("log", log);
        return "logModify";        
    }
    
    public String del() throws Exception{
        if (logService.del(lid)) {
            List<Log> logList=logService.findByUid(uid);
            request.setAttribute("logList", logList);
            return "success";
        }
        return "failed";
    }
    
    public String modify () throws Exception {
        System.out.println("修改："+log.toString());
        if (logService.modify(log)) {
            return  "success";
        }
        return  "failed";
    }
}

package com.sxl.actions;

import javax.servlet.http.HttpServletRequest;

import org.apache.struts2.ServletActionContext;

import com.opensymphony.xwork2.ActionSupport;
import com.sxl.pojos.User;
import com.sxl.services.LogService;
import com.sxl.services.UserService;

public class UserAction extends ActionSupport {
        private User user;
        private String validatePass;
        
        //提取出公共的部分
        private UserService userService=new UserService();
        HttpServletRequest request=ServletActionContext.getRequest();
        
        public User getUser() {
            return user;
        }
        public void setUser(User user) {
            this.user = user;
        }
        public String getValidatePass() {
            return validatePass;
        }
        public void setValidatePass(String validatePass) {
            this.validatePass = validatePass;
        }
        
        //用户登录
        public String login() throws Exception {
            int uid=userService.find(user);
            if (uid!=-1) {
                user.setUid(uid);
                request.getSession().setAttribute("user", user);
                return "personalCenter";
            }else {
                return "failed";
            }            
        }
        
        //添加用户
        public String add() throws Exception {
            if (!user.getPass().equals(validatePass)) {
                return "failed";
            }
            if (userService.add(user)) {
                return "personalCenter";
            }else {
                return "failed";
            }
        }
        
        public String modify() throws Exception{
            if (!user.getPass().equals(validatePass)) {
                return "failed";
            }if (userService.modify(user)) {
                return "success";
            }else {
                return "failed";
            }
        }        
}

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC "-//Apache Software Foundation//DTD Struts Configuration 2.1//EN" "http://struts.apache.org/dtds/struts-2.1.dtd">
<struts>

    <package name="logsystem" namespace="/" extends="struts-default">
        <action name="user" class="com.sxl.actions.UserAction">
            <result name="personalCenter" type="dispatcher">/personalCenter.jsp</result>
            <result name="success" type="dispatcher">/success.jsp</result>
            <result name="failed" type="redirect">/failed.jsp</result>
        </action>
        
        <action name="log" class="com.sxl.actions.LogAction">
            <result name="getAllLog" type="dispatcher">/getAllLog.jsp</result>
            <result name="success" type="dispatcher">/success.jsp</result>
            <result name="logModify" type="dispatcher">/logModify.jsp</result>
            <result name="failed" type="redirect">/failed.jsp</result>
        </action>        
    </package>
</struts>