filemanager.java

bbs论坛系统

package struts.business;

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


public class FileManager {
    
	
	
	Connection con=null;
	PreparedStatement stmt=null;
	DBUtility db;
	private static final String downloadFile="Select * from uploadfile where filename=?";
	private static final String insertFile="insert into uploadfile(filetitle,describe,fileurl,strfs,filetype,filename) values(?,?,?,?,?,?)";
	private static final String deleteFile="delete from uploadfile where filename=?";

	public int insert(String filetitle,String describe,String fileurl, String strfs, String filetype,String filename) throws Exception 
	{  
		int result=0;
		//Connection con=null;
		//String strSql;
		DBUtility db=DBUtility.getInstance();
		try
		{    
			con=db.getConnection();
		    stmt=con.prepareStatement(insertFile);
			stmt.setString(1,filetitle);
			stmt.setString(2,describe);
			stmt.setString(3,fileurl);
			stmt.setString(4,strfs);
			stmt.setString(5,filetype);
			stmt.setString(6,filename);
			result=stmt.executeUpdate();
			con.close();
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
		}
		return result;
	}
	public int delete(String filename)
	{
		int result=0;		
		try
		{
			con=db.getConnection();
		    stmt=con.prepareStatement(insertFile);
			stmt.setString(1, filename);
			result=stmt.executeUpdate();
			con.close();
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
		}
		return result;
	}
	
	public boolean download(String filename)
	{
		return true;
	}
	//下面这个方法是从数据库中得到文件的路径
	public String filepath(String fileid)
	{
		int id=Integer.valueOf(fileid).intValue();
		String filepath="select * from uploadfile where id="+id;
		DBUtility db=DBUtility.getInstance();
		Statement sql=null;
		ResultSet rs=null;
		try
		{    
			con=db.getConnection();
			sql=con.createStatement();
			rs=sql.executeQuery(filepath);
			rs.next();
			String url=rs.getString("fileurl");
			return url;
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
			return null;
		}
	 }
		//更新下载次数
	public int addtimes(String fileid) {
			
		int id=Integer.valueOf(fileid).intValue();
		String add_times="update uploadfile set download_times=download_times+1 where id="+id;
		DBUtility db=DBUtility.getInstance();
		Statement sql=null;
		int add=0;
		try
		{    
			con=db.getConnection();
			sql=con.createStatement();
			add=sql.executeUpdate(add_times);
			return add;
		}
		catch(Exception e)
		{
			System.out.println(e.getMessage());
			return 0;
		}
			
	}
			
	public static void main(String arg[]) 
	{
		try{
			FileManager fm=new FileManager();
			int b=1;
			b=fm.addtimes("6");
			System.out.print(b);
		}
		
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
	
}