controldatabase.java

java编程好的网上银行的例子

/*
 * 创建日期 2005-9-5
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
import java.sql.*;
import java.util.*;

public class ControlDataBase {

    //private String classForName = "org.gjt.mm.mysql.Driver";
    private String classForName = "Driver.MySQL.mysql.src.com.mysql.jdbc.Driver";
    // check log in user
    public int isRightUser(int accountNumber, String password) {
        String pwd = null;
        try {
            Class.forName(classForName).newInstance();
            Connection c2 = DriverManager.getConnection(
                    "jdbc:mysql://cy:3306/rmi", "njchenyi", "");

            String sql2 = "select * from Password";
            //String sql2 = "select Password from Client where UserID = '"
            //        + accountNumber + "';";
            Statement smt = c2.createStatement();

            ResultSet r2 = smt.executeQuery(sql2);
            while (r2.next()) {
                pwd = r2.getString(1);

            }
            if (pwd.equals(password)) {
                return accountNumber;
            }

        } catch(ClassNotFoundException e) { 
            System.out.println("找不到驱动程序"); 
            e.printStackTrace(); 
            return 0;
            } 
            catch(Exception e) { 
                System.err.println(e.getMessage());
            e.printStackTrace(); 
            return 0;
        }
        return 1;
    }

    // get all the user
    public Vector getAllUsers() {
        Vector users = new Vector();
        try {
            Class.forName(classForName);
            Connection c2 = DriverManager.getConnection(
                    "jdbc:mysql://cy:3306/rmi", "root", "99104112");

            String sql2 = "select name from user ";
            Statement smt = c2.createStatement();
            ResultSet r2 = smt.executeQuery(sql2);

            while (r2.next()) {
                // users.addElement( (String) r2.getObject(1));
                users.addElement(r2.getString(1));
            }

            smt.close();

            return users;

        } catch (Exception e) {
            System.out.println("Database connection fail" + e.getMessage());
            return null;
        }
    }

    public Vector getAllUser() {
        Vector allUser = new Vector();

        try {
            Class.forName(classForName);
            Connection c2 = DriverManager.getConnection(
                    "jdbc:mysql://cy:3306/rmi", "root", "99104112");

            String sql2 = "select name,email,mobile,local from user ";
            Statement smt = c2.createStatement();
            ResultSet r2 = smt.executeQuery(sql2);

            while (r2.next()) {
                Vector row = new Vector();
                row.addElement(r2.getString("name"));
                row.addElement(r2.getString("email"));
                row.addElement(r2.getString("mobile"));
                row.addElement(r2.getString("local"));
                allUser.addElement(row);
            }
            // System.out.println(allUser);
            smt.close();
            return allUser;

        } catch (Exception e) {
            System.out.println("Database connection fail" + e.getMessage());
            return null;
        }
    }

    public void delUser(String name) {
        try {
            Class.forName(classForName);
            Connection c2 = DriverManager.getConnection(
                    "jdbc:mysql://cy:3306/rmi", "root", "99104112");

            String sql2 = "delete * from user where name = '" + name + "';";
            Statement smt = c2.createStatement();
            ResultSet r2 = smt.executeQuery(sql2);
            smt.close();
        } catch (Exception e) {
        }
    }

    public void addUser(String name, String password, String email,
            String mobile, String local) {
        try {
            Class.forName(classForName);
            Connection c2 = DriverManager.getConnection(
                    "jdbc:mysql://cy:3306/rmi", "root", "99104112");

            String sql2 = "insert into user values('" + name + "','" + password
                    + "','" + email + "','" + mobile + "','" + local + "');";
            Statement smt = c2.createStatement();
            ResultSet r2 = smt.executeQuery(sql2);
            smt.close();
        } catch (Exception e) {
        }
    }
}