新建 文本文档 (3).txt

java超市项目的项目源码,这是非常好的,写的很规范的源码呀.

import java.sql.*;
import java.util.*;
import newsdemo.*;

public class OracleBean {
    private int totalRow;
    private String driver = "oracle.jdbc.driver.OracleDriver";
    private String serverName = "172.17.92.108";
    private String oraUserid = "scott";
    private String oraPassword = "tiger";
    private String url = "jdbc:oracle:thin:@" + serverName + ":1521:ora";
    private Connection conn;
    private ResultSet rs;
    public OracleBean() {
        try {
            Class.forName(driver);
        } catch (ClassNotFoundException ex) {
            ex.printStackTrace();
        }
    }

    public void addMessage(MessageVo msg){
      String sql="insert into news values(seq_news_Id.nextval,'"+msg.getTitle()+"','"+msg.getAuthor()+"','"+msg.getContent()+"',sysdate)";
      this.update(sql);
    }

    public Collection getMessage() throws Exception {
        Collection coll = new ArrayList();
        String sql = "select * from news";
        ResultSet rs = this.query(sql);
        while (rs.next()) {
            MessageVo msg = new MessageVo();
            msg.setId(rs.getInt("Id"));
            msg.setTitle(rs.getString("Title"));
            msg.setAuthor(rs.getString("Author"));
            msg.setContent(rs.getString("Content"));
            msg.setAdddate(rs.getDate("Adddate"));
            coll.add(msg);
        }
        return coll;
    }

    public MessageVo getMessage2(int id) throws Exception {
            Collection coll = new ArrayList();
            String sql = "select * from news where Id="+id;
            ResultSet rs = this.query(sql);
            rs.next();
                MessageVo msg = new MessageVo();
                msg.setTitle(rs.getString("Title"));
                msg.setAuthor(rs.getString("Author"));
                msg.setContent(rs.getString("Content"));
                msg.setAdddate(rs.getDate("Adddate"));
       return msg;
      }

    public int getZongshu() throws Exception{
    String sql = "select count(*) a from news";
    ResultSet rs = this.query(sql);
    rs.next();
    totalRow=rs.getInt("a");
    return totalRow;
  }

    public ResultSet query(String sql) {
        try {
            conn = DriverManager.getConnection(url, oraUserid, oraPassword);
            Statement stmt = conn.createStatement(ResultSet.
                                                  TYPE_SCROLL_INSENSITIVE,
                                                  ResultSet.CONCUR_READ_ONLY);
            rs = stmt.executeQuery(sql);
        } catch (SQLException ex) {
            ex.printStackTrace();

        }
        return rs;
    }

    public void update(String sql) {
        try {
            conn = DriverManager.getConnection(url, oraUserid, oraPassword);
            Statement stmt = conn.createStatement();
            stmt.executeUpdate(sql);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
}