package dao;

import java.io.Serializable;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import entity.Admin;
import util.DBUtil;

public class AdminDao implements Serializable {

    public Admin findByCode(String code) {
        Connection conn = null;
        try {
            conn = DBUtil.getConnection();
            String sql = 
                "select * from admin_info_lhh "
                + "where admin_code=?";
            PreparedStatement ps = 
                conn.prepareStatement(sql);
            ps.setString(1, code);
            ResultSet rs = ps.executeQuery();
            if(rs.next()) {
                Admin a = new Admin();
                a.setAdminId(rs.getInt("admin_id"));
                a.setAdminCode(rs.getString("admin_code"));
                a.setPassword(rs.getString("password"));
                a.setName(rs.getString("name"));
                a.setTelephone(rs.getString("telephone"));
                a.setEmail(rs.getString("email"));
                a.setEnrolldate(rs.getTimestamp("enrolldate"));
                return a;
            }
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(
                "查询管理员失败", e);
        } finally {
            DBUtil.close(conn);
        }
        return null;
    }
    
    public static void main(String[] args) {
        AdminDao dao = new AdminDao();
        Admin a = dao.findByCode("caocao");
        if(a != null) {
            System.out.println(a.getAdminId());
            System.out.println(a.getName());
        }
    }
    
}

package dao;

import java.io.Serializable;
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 entity.Cost;
import util.DBUtil;

public class CostDao implements Serializable {

    public List<Cost> findAll() {
        Connection conn = null;
        try {
            conn = DBUtil.getConnection();
            String sql = 
                "select * from cost_lhh "
                + "order by cost_id";
            Statement smt = conn.createStatement();
            ResultSet rs = smt.executeQuery(sql);
            List<Cost> list = new ArrayList<Cost>();
            while(rs.next()) {
                Cost c = new Cost();
                c.setCostId(rs.getInt("cost_id"));
                c.setName(rs.getString("name"));
                c.setBaseDuration(rs.getInt("base_duration"));
                c.setBaseCost(rs.getDouble("base_cost"));
                c.setUnitCost(rs.getDouble("unit_cost"));
                c.setStatus(rs.getString("status"));
                c.setDescr(rs.getString("descr"));
                c.setCreatime(rs.getTimestamp("creatime"));
                c.setStartime(rs.getTimestamp("startime"));
                c.setCostType(rs.getString("cost_type"));
                list.add(c);
            }
            return list;
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(
                "查询资费失败",e);
        } finally {
            DBUtil.close(conn);
        }
    }
    
    public static void main(String[] args) {
        CostDao dao = new CostDao();
        Cost c = new Cost();
        c.setName("包月");
        //c.setBaseDuration(660);
        c.setBaseCost(1200.0);
        //c.setUnitCost(0.6);
        c.setDescr("包月很爽");
        c.setCostType("1");
        dao.save(c);
    }
    
    public void save(Cost c) {
        Connection conn = null;
        try {
            conn = DBUtil.getConnection();
            String sql = 
                "insert into cost_lhh "
                + "values(cost_seq_lhh.nextval,"
                + "?,?,?,?,‘1‘,?,sysdate,null,?)";
            PreparedStatement ps = 
                conn.prepareStatement(sql);
            ps.setString(1, c.getName());
            //JDBC的方法setInt()/setDouble(),
            //不允许传入null,但当前业务该字段
            //确实可能为null,并且数据库中该字段
            //也允许是null.
            //解决办法:将这样的数据当做对象处理.
            ps.setObject(2, c.getBaseDuration());
            ps.setObject(3, c.getBaseCost());
            ps.setObject(4, c.getUnitCost());
            ps.setString(5, c.getDescr());
            ps.setString(6, c.getCostType());
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(
                "增加资费失败", e);
        } finally {
            DBUtil.close(conn);
        }
    }
    
}