www.pudn.com > RFID_98798798698698.rar > TGetProductsDAO.java

/** 
 *  
 */ 
package com.rfid.dao; 
 
import java.sql.Connection; 
import java.sql.PreparedStatement; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Timestamp; 
import java.util.ArrayList; 
import java.util.Date; 
import java.util.List; 
 
import com.rfid.global.DbUtil; 
import com.rfid.model.TGetProducts; 
import com.rfid.model.TInStore; 
/** 
 * @author yesiwill 
 * 
 */ 
public class TGetProductsDAO { 
 
	/** 
	 * @param args 
	 */ 
	 
	public int insert(TGetProducts getproducts) { 
		int result = 0; 
		//System.out.print(result); 
		Connection conn = DbUtil.getConnection(); 
		PreparedStatement stmt = null; 
		 
		String sqlStr = "insert into t_getproducts(order_id,name,number,input_time,input_user,isget) "; 
		sqlStr += "values (?,?,?,?,?,?)"; 
 
		try { 
			stmt = conn.prepareStatement(sqlStr); 
			conn.setAutoCommit(false); 
			stmt.setInt(1, getproducts.getOrder_id()); 
			stmt.setString(2, getproducts.getName()); 
			stmt.setInt(3, getproducts.getNumber()); 
			stmt.setTimestamp(4, Timestamp.valueOf(new Date().toLocaleString())); 
			stmt.setInt(5, getproducts.getInput_user()); 
			stmt.setInt(6, getproducts.getIsget()); 
			 
			result = stmt.executeUpdate(); 
			//System.out.print(result); 
			conn.commit(); 
		} catch (Exception e) { 
			try { 
				conn.rollback(); 
			} catch (SQLException e1) { 
				// TODO Auto-generated catch block 
				e1.printStackTrace(); 
			} 
		} finally { 
			try { 
				stmt.close(); 
				conn.close(); 
			} catch (SQLException e) { 
				// TODO Auto-generated catch block 
				e.printStackTrace(); 
			} 
		} 
 
		return result; 
	} 
	 
	public int getLastId(){ 
		int LastId = 0; 
		Connection conn = DbUtil.getConnection(); 
		PreparedStatement stmt = null; 
		ResultSet rs = null; 
		//TGetProducts getproducts = new TGetProducts(); 
		 
		String sqlStr = "select id from t_getproducts where id >= ALL(select id from t_getproducts)"; 
 
		try { 
			stmt = conn.prepareStatement(sqlStr); 
			conn.setAutoCommit(false); 
			rs = stmt.executeQuery(); 
			conn.commit(); 
			 
			if (rs.next()) { 
				LastId = rs.getInt("id"); 
			} 
		} catch (Exception e) { 
			try { 
				conn.rollback(); 
			} catch (SQLException e1) { 
				// TODO Auto-generated catch block 
				e1.printStackTrace(); 
			} 
		} finally { 
			try { 
				stmt.close(); 
				conn.close(); 
			} catch (SQLException e) { 
				// TODO Auto-generated catch block 
				e.printStackTrace(); 
			} 
		} 
 
		return LastId; 
	} 
	 
	public List getOutProducts() { 
		List list = new ArrayList(); 
 
		String sqlStr = "select * from t_getproducts where isget=0 order by id"; 
		Connection conn = DbUtil.getConnection(); 
		PreparedStatement stmt = null; 
		ResultSet rs = null; 
		try { 
			stmt = conn.prepareStatement(sqlStr); 
			conn.setAutoCommit(false); 
			rs = stmt.executeQuery(); 
			conn.commit(); 
 
			/* 遍历将rs中的结果插入list中返回 */ 
			if (rs != null) { 
				TGetProducts getproduct = null; 
				while (rs.next()) { 
					getproduct = new TGetProducts(); 
					getproduct.setId(rs.getInt("id")); 
					getproduct.setName(rs.getString("name")); 
					getproduct.setNumber(rs.getInt("number")); 
					getproduct.setInput_time(rs.getDate("input_time")); 
					getproduct.setOrder_id(rs.getInt("order_id")); 
					getproduct.setInput_user(rs.getInt("input_user")); 
					list.add(getproduct); 
				} 
			} 
		} catch (SQLException e) { 
			// TODO Auto-generated catch block 
			e.printStackTrace(); 
		} finally { 
			try { 
				rs.close(); 
				stmt.close(); 
				conn.close(); 
			} catch (SQLException e) { 
				// TODO Auto-generated catch block 
				e.printStackTrace(); 
			} 
		} 
		return list; 
	}  
	 
 
}