registerbean.java

一个用java实现的bbs论坛系统...........................

/**
 * @author [e-mail]
 * @version v0 110400
 */

import java.sql.*;

public class RegisterBean {

    private static final boolean DEBUG = false;

	private String acctName;
	public String getAcctName() { return acctName; }
	public void setAcctName(String s) { acctName = s; }

	private String password;
	public String getPassword() { return password; }
	public void setPassword(String s) { password = s; }

	private String password2; // for confirmation (hold)
	public String getPassword2() { return password2; }
	public void setPassword2(String s) { password2 = s; }

    private Connection conn;
    
	public RegisterBean() {
		acctName = null;
		password = null;
		password2 = null;

        // Get connection:
        try {
            Class.forName("oracle.jdbc.driver.OracleDriver");
            conn = DriverManager.getConnection
                    ("jdbc:oracle:oci8:@JavaBBS.woexpert", "bbsdev", "bbsdev");
        } catch (ClassNotFoundException e) {
            System.err.println("Err: " + e.getMessage());
        } catch (SQLException e) {
            System.err.println("Err: " + e.getMessage());
        }
	}

    protected void finalize() throws Throwable {
        try {
            conn.close();
        } catch (SQLException e) {
            System.err.println("Err: " + e.getMessage());
        }
        super.finalize();
    }
    
    /**
     * @return boolean is succeeded
     */
    public boolean insertNewCustomerWithId(int nCustomerId) {
        String sSqlStmt = "insert into customer (id, acct_name, pwd_enc)" +
            " values (" + nCustomerId + ", '" + acctName + "', ?)";
        if (DEBUG) System.out.println("sSqlStmt:\n" + sSqlStmt);
        
        try {
	        PreparedStatement pstmt = conn.prepareStatement(sSqlStmt);
        	byte [] pbytePwdEnc = A1Encryption.encryptPwd(password);
        	pstmt.setBytes(1, pbytePwdEnc);
        	pstmt.executeUpdate();
        	pstmt.close();
	        return true;
    	} catch (SQLException e) {
    		System.err.println("Err: " + e.getMessage());
    		return false;
    	}
    }
    
    public int fetchNewCustomerId() {
        String sSqlStmt = "select customer_seq.nextval from dual";
		try {
	        Statement stmt = conn.createStatement();
        	ResultSet rs = stmt.executeQuery(sSqlStmt);
        	rs.next();
        	int nCustomerId = rs.getInt(1);
        	rs.close();
        	stmt.close();
			return nCustomerId;
		} catch (SQLException e) {
			System.err.println("Err: " + e.getMessage());
			return -1; // (tmp)
		}
	}    	
    
}