attachment.java

来自「一个用java编写的功能强大的OA系统」· Java 代码 · 共 202 行

package com.redmoon.oa.task;

import java.io.File;
import java.sql.*;

import cn.js.fan.db.Conn;
import cn.js.fan.web.Global;
import org.apache.log4j.Logger;

public class Attachment implements java.io.Serializable {
    int id;
    int taskId;
    String name;
    String fullPath;
    String diskName;
    String visualPath;

    String connname;

    String CREATE = "insert into task_attach (taskId,name,fullPath, diskName,visualPath) values (?,?,?,?,?)";
    String LOAD = "SELECT taskId, name, fullpath, diskname, visualpath FROM task_attach WHERE id=?";
    String SAVE = "update task_attach set taskId=?, name=?, fullpath=?,skname=?, visualpath=? WHERE id=?";

    Logger logger = Logger.getLogger(Attachment.class.getName());

    public Attachment() {
        connname = Global.defaultDB;
    }

    public Attachment(int id) {
        connname = Global.defaultDB;
        if (connname.equals(""))
            logger.info("Attachment:默认数据库名为空！");
        this.id = id;
        load();
    }

    public boolean create() {
        Conn conn = new Conn(connname);
        boolean re = false;
        try {
            PreparedStatement ps = conn.prepareStatement(CREATE);
            ps.setInt(1, taskId);
            ps.setString(2, name);
            ps.setString(3, fullPath);
            ps.setString(4, diskName);
            ps.setString(5, visualPath);
            re = conn.executePreUpdate()==1?true:false;
        }
        catch (SQLException e) {
            logger.error("del:" + e.getMessage());
            return false;
        }
        finally {
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
        return re;
    }

    public boolean del() {
        String sql = "delete from task_attach where id=?";
        Conn conn = new Conn(connname);
        boolean re = false;
        try {
            PreparedStatement pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, id);
            re = conn.executePreUpdate()==1?true:false;
        }
        catch (SQLException e) {
            logger.error("del:" + e.getMessage());
            return false;
        }
        finally {
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
        
        File fl = new File(this.fullPath);
        fl.delete();
        return re;
    }

    public boolean save() {
        Conn conn = new Conn(connname);
        boolean re = false;
        try {
            PreparedStatement pstmt = conn.prepareStatement(SAVE);
            pstmt.setInt(1, taskId);
            pstmt.setString(2, name);
            pstmt.setString(3, fullPath);
            pstmt.setString(4, diskName);
            pstmt.setString(5, visualPath);
            pstmt.setInt(6, id);
            re = conn.executePreUpdate()==1?true:false;
        }
        catch (SQLException e) {
            logger.error(e.getMessage());
        }
        finally {
            if (conn!=null) {
                conn.close(); conn = null;
            }
        }
        return re;
    }

    public int getId() {
        return this.id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public int getTaskId() {
        return this.taskId;
    }

    public void setTaskId(int taskId) {
        this.taskId = taskId;
    }

    public String getName() {
        return this.name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getDiskName() {
        return this.diskName;
    }

    public void setDiskName(String dn) {
        this.diskName = dn;
    }

    public String getFullPath() {
        return this.fullPath;
    }

    public void setFullPath(String f) {
        this.fullPath = f;
    }

    public String getVisualPath() {
        return this.visualPath;
    }

    public boolean isLoaded() {
        return loaded;
    }

    public void setVisualPath(String vp) {
        this.visualPath = vp;
    }

    public void setLoaded(boolean loaded) {
        this.loaded = loaded;
    }

    public void load() {
        Conn conn = new Conn(connname);
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            pstmt = conn.prepareStatement(LOAD);
            pstmt.setInt(1, id);
            rs = conn.executePreQuery();
            if (rs != null && rs.next()) {
                taskId = rs.getInt(1);
                name = rs.getString(2);
                fullPath = rs.getString(3);
                diskName = rs.getString(4);
                visualPath = rs.getString(5);
                loaded = true;
            }
        } catch (SQLException e) {
            logger.error("load" + e.getMessage());
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (Exception e) {}
                rs = null;
            }
            if (conn != null) {
                conn.close();
                conn = null;
            }
        }
    }

    private int orders = 0;
    private int pageNum;
    private boolean loaded = false;
}