filelinkdao.java

servlet实现网上书店查询

package com.ghy.bookstore.load.dao;

import java.io.IOException;
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 com.ghy.base.dao.BaseDao;
import com.ghy.bookstore.load.model.FileLinkVO;

public class FileLinkDao extends BaseDao {
	public void setFileLink(FileLinkVO filelink) throws IOException,
			InstantiationException, IllegalAccessException,
			ClassNotFoundException, SQLException {
		Connection conn = getDatamanager().getConnection();
		filelink.setId(generateId(conn));
		String sql = "insert  into filelink(id, filename, filelink, userid) values (?,?,?,?) ";
		PreparedStatement statement = conn.prepareStatement(sql);
		statement.setString(1, filelink.getId());
		statement.setString(2, filelink.getFilename());
		statement.setString(3, filelink.getFilelink());
		statement.setString(4, filelink.getUserid());
		statement.execute();
		getDatamanager().closeDBConnection();
	}

	public ArrayList getFileLink() throws IOException, InstantiationException,
			IllegalAccessException, ClassNotFoundException, SQLException {
		Connection conn = getDatamanager().getConnection();
		String sql = "select * from filelink";
		Statement statement = conn.createStatement();
		ResultSet rs = statement.executeQuery(sql);
		ArrayList list = new ArrayList();
		while (rs.next()) {
			FileLinkVO filelink = new FileLinkVO();
			filelink.setFilename(rs.getString("filename"));
			filelink.setFilelink(rs.getString("filelink"));
			filelink.setId(rs.getString("id"));

			list.add(filelink);
		}
		getDatamanager().closeDBConnection();
		return list;

	}

	public void deleteFileLink(String id) throws IOException,
			InstantiationException, IllegalAccessException,
			ClassNotFoundException, SQLException {
		Connection conn = getDatamanager().getConnection();
		String sql = "delete from FILELINK where id=?";
		PreparedStatement statement = conn.prepareStatement(sql);
		statement.setString(1, id);
		statement.executeQuery();
		getDatamanager().closeDBConnection();
	}

}