broaddaoimp.java

JAVA视频播放器 源码相当详细 功能强大

package com.video.broad.dao.jdbc;

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 javax.sql.DataSource;


import com.video.broad.dao.BroadDao;
import com.video.domain.Sp;

public class BroadDaoImp implements BroadDao{
	
	Connection conn = null;
	private void closeConnection() {
		try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	@Override
	public ArrayList<Sp> getShipin(DataSource ds) {
		ArrayList<Sp> shipins=new ArrayList<Sp>();
		
		try {
			conn = ds.getConnection();
			Statement stmt =conn.createStatement();
			ResultSet rs=stmt.executeQuery("select name from sp");
			while(rs.next()){
				Sp s=new Sp();
				s.setName(rs.getString("name"));
				shipins.add(s);
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			/* 取消連接　*/
			if (conn != null) {
				closeConnection();
			}
		}
		return shipins;
		
	}

	@Override
	public Sp getUrl(DataSource ds, String name) {
		Sp s=new Sp();
		try {
			conn = ds.getConnection();
			PreparedStatement ps = conn
			.prepareStatement("select id,url,name,remark from sp where name=?");
			/* 顧客のコード　*/
			ps.setString(1,name);
			/* SQL文の実行　*/
			ResultSet rs = ps.executeQuery();
			while(rs.next()){
				s.setId(rs.getString("id"));
				s.setUrl(rs.getString("url"));
				s.setName(rs.getString("name"));
				s.setRemark(rs.getString("remark"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return s;
	}

}