filebase.java

Java协同办公系统。实现公司内部的人事

package com.icss.oa.base;

import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import com.icss.oa.service.FileService;
import com.icss.oa.utils.*;
import com.icss.oa.bean.FileVO;

public class FileBase {

	public static List fileQuery(String sqlStr){
		List filesList=new ArrayList();
		System.out.println(sqlStr);
		Connection conn=ConnectionFactory.getConnection();
		Statement stmt=null;
		ResultSet rs=null;
		try {
			stmt=conn.createStatement();
			rs=stmt.executeQuery(sqlStr);
			while(rs.next()){
				FileVO file=new FileVO();
				int userId=rs.getInt("personId");
				file.setUserId(userId);
				int fileId=rs.getInt("fileId");
				file.setFileId(fileId);
				String fileName=rs.getString("fileName");
				file.setFileName(fileName);
				String filePath=rs.getString("path");
				file.setPath(filePath);
				int isFile=rs.getInt("isFile");
				file.setIsFile(isFile);
				int isShare=rs.getInt("isShare");
				file.setIsShare(isShare);
				filesList.add(file);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DatabaseUtils.release(rs, stmt, conn);
		}
		return filesList;
	}
	public static boolean isFileExist(int userId,String path){
		boolean flag=false;
		Connection conn=ConnectionFactory.getConnection();
		Statement stmt=null;
		ResultSet rs=null;
		try {
			stmt=conn.createStatement();
			String query="select * from t_file where personId="+userId+" and path='"+path+"'";
			System.out.println(query);
			rs=stmt.executeQuery(query);
			if(rs.next()){
				flag=true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DatabaseUtils.release(rs, stmt, conn);
		}
		return flag;
	}
	public static boolean fileUpdate(String sqlStr){
		System.out.println(sqlStr);
		boolean flag=false;
		Connection conn=ConnectionFactory.getConnection();
		Statement stmt=null;
		try {
			stmt=conn.createStatement();
			if(stmt.executeUpdate(sqlStr)>0){
				flag=true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			DatabaseUtils.release(null, stmt, conn);
		}
		return flag;
	}
	public static List queryAllObject(String sqlStr) {
		System.out.println(sqlStr);
		
		List lists = new ArrayList();

		Properties prop = null;
		Connection conn=null;
		Statement stmt=null;
		ResultSet rs=null;
		
		try{
			
				conn = ConnectionFactory.getConnection();
				
				stmt=conn.createStatement();
				
				rs = stmt.executeQuery(sqlStr);
			
				ResultSetMetaData rsmd = rs.getMetaData();
				
				int countColumn = rsmd.getColumnCount();
				
				while(rs.next()){
					
					prop = new Properties();
					for(int columnIndex= 1;columnIndex<=countColumn;columnIndex++){
						String value=rs.getString(rsmd.getColumnName(columnIndex));
						if(value!=null){
							prop.put(rsmd.getColumnName(columnIndex),value);
						}
						System.out.println(rsmd.getColumnName(columnIndex)+":"+value);
						
					}

					lists.add(prop);

				}
		} catch (Exception e) {
		
			e.printStackTrace();
		
		
		}finally{
			DatabaseUtils.release(rs, stmt, conn);
		}
			return lists;
}
	

}