userdao.java

这个是j2eejava web 编程精要十五讲的全部源码。对学习java web编程的人来说是很能得的资料

package test;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import javax.sql.DataSource;

public class UserDAO implements IUserDAO {
    private DataSource dataSource;
    
    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }
    
    public void insert(User user) {
       String name = user.getName();
       int age = user.getAge().intValue();
       
       Connection conn = null;
       Statement stmt = null;
       
        try {
            conn = dataSource.getConnection();
            stmt = conn.createStatement();
            stmt.execute("INSERT INTO user (name,age) " 
                 + "VALUES('" + name + "'," + age + ")");
        } catch (SQLException e) {
            e.printStackTrace();
        }
        finally {
            if(stmt != null) {
                try {
                    stmt.close();
                }   
                catch(SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null) {
                try {
                    conn.close();
                }
                catch(SQLException e) {
                    e.printStackTrace();
                }
            }
        } 
    }

    public User find(Integer id) {
        Connection conn = null;
        Statement stmt = null;
        
         try {
             conn = dataSource.getConnection();
             stmt = conn.createStatement();
             
             ResultSet result = stmt.executeQuery(
                 "SELECT * FROM user WHERE id=" + id.intValue());
             if(result.next()) {
                 Integer i = new Integer(result.getInt(1));
                 String name = result.getString(2);
                 Integer age = new Integer(result.getInt(3));
                 
                 User user = new User();
                 user.setId(i);
                 user.setName(name);
                 user.setAge(age);
                 
                 return user;
             }
         } catch (SQLException e) {
             e.printStackTrace();
         }
         finally {
             if(stmt != null) {
                 try {
                     stmt.close();
                 }   
                 catch(SQLException e) {
                     e.printStackTrace();
                 }
             }
             if(conn != null) {
                 try {
                     conn.close();
                 }
                 catch(SQLException e) {
                     e.printStackTrace();
                 }
             }
         }    
         
         return null;
    }
}