Jsp+Servlet实现文件上传下载 删除上传文件(三)(jsp是什么文件的扩展名)墙裂推荐

随心笔谈11个月前发布 admin
89 0


package dao.upload;

import entity.upload.EntityAccessory;
import util.DBUtil;

import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class AccessoryDao {
public static void add(EntityAccessory entity) {
Connection conn=DBUtil.getConnection();
String sql=”insert into tbl_accessory(file_name,file_size,file_ext_name,file_path) values(?,?,?,?)”;
try {
PreparedStatement ps=conn.prepareStatement(sql);
ps.setString(1, entity.getFileName());
ps.setDouble(2, entity.getFileSize());
ps.setString(3, entity.getFile_ext_name());
ps.setString(4, entity.getFilePath());
ps.execute();
//conn.commit();

DBUtil.close(null, ps, conn);
} catch (SQLException e) {
e.printStackTrace();
}
}

public static List<EntityAccessory> list() {
Connection conn=DBUtil.getConnection();
String sql=”select id,file_name,file_size,file_ext_name,file_path from tbl_accessory”;
List<EntityAccessory> accessoryList=new ArrayList<>();
try {
PreparedStatement ps=conn.prepareStatement(sql);
ResultSet rs=ps.executeQuery();

while (rs.next()) {
EntityAccessory entity=new EntityAccessory();
entity.setId(rs.getInt(“id”));
entity.setFileName(rs.getString(“file_name”));
entity.setFileSize(new BigDecimal(rs.getDouble(“file_size”) / 1024).setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
entity.setFile_ext_name(rs.getString(“file_ext_name”));
entity.setFilePath(rs.getString(“file_path”));
accessoryList.add(entity);
}

DBUtil.close(rs, ps, conn);
} catch (SQLException e) {
e.printStackTrace();
}

return accessoryList;

}

public static EntityAccessory load(int id){
Connection conn=DBUtil.getConnection();
PreparedStatement ps=null;
ResultSet rs=null;
EntityAccessory entity=new EntityAccessory();
String sql=”select id, file_name,file_size,file_ext_name,file_path from tbl_accessory where id=?”;
try {
ps=conn.prepareStatement(sql);
ps.setInt(1,id);
rs=ps.executeQuery();
while (rs.next()){
entity.setId(rs.getInt(“id”));
entity.setFileName(rs.getString(“file_name”));
entity.setFileSize(rs.getDouble(“file_size”));
entity.setFile_ext_name(rs.getString(“file_ext_name”));
entity.setFilePath(rs.getString(“file_path”));
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
DBUtil.close(rs,ps,conn);
}

return entity;
}

public static void remove(int id) {
Connection conn=DBUtil.getConnection();
String sql=”delete from tbl_accessory where id=?”;
try {
PreparedStatement ps=conn.prepareStatement(sql);
ps.setInt(1,id);
ps.execute();
//conn.commit(); mysql默认开启了autocommit

DBUtil.close(null,ps,conn);
} catch (SQLException e) {
e.printStackTrace();
}
}
}

© 版权声明

相关文章