userservice.java

购物车,struts+jdbc 数据库sqlserver2

package org.y2t12.service;

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

import org.y2t12.beans.BookBean;
import org.y2t12.common.DBConnection;

public class UserService {
	/**
	 * 查找到所有的书
	 * 
	 * @return list
	 */
	public List findAll() {
		List list = new ArrayList();
		String sql = "SELECT id,title,descn,price,author FROM books";
		Statement st = null;
		ResultSet rs = null;
		Connection con = DBConnection.getConnection();

		try {
			st = con.createStatement();
			rs = st.executeQuery(sql);
			while (rs.next()) {
				BookBean book = new BookBean();

				book.setId(rs.getInt(1));
				book.setTitle(rs.getString(2));
				book.setDescn(rs.getString(3));
				book.setPrice(rs.getFloat(4));
				book.setAuthor(rs.getString(5));

				list.add(book);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(con, st, rs);
		}

		return list;
	}
	/**
	 * 添加书籍
	 * @param 业务实体Bean
	 */
	public void appendBook(BookBean bean) {
		String sql = "INSERT INTO books(title,descn,price,author) VALUES(?,?,?,?)";
		PreparedStatement ps = null;
		Connection con = DBConnection.getConnection();

		try {
			ps = con.prepareStatement(sql);
			ps.setString(1, bean.getTitle());
			ps.setString(2, bean.getDescn());
			ps.setFloat(3,bean.getPrice());
			ps.setString(4, bean.getAuthor());
			
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(con, ps);
		}
	}
}