[零基础学JAVA]Java SE实战开发-37.MIS信息管理系统实战开发[JDBC](1)-阿里云开发者社区

MIS信息管理系统实战开发之使用MySQL实现保存

开发背景

ID、姓名、年龄为公共信息，而学生有成绩，工人有工资

定义一个抽象类Person（ID、姓名、年龄），学生是其子类，有成绩，工人是其子类有工资

ID如何定义呢？
ID最好可以自己生成，最好的方式是采用下面的编码方式：
· 标记 + 时间戳 + 三位随机数
· 例如：2009年3月22 20:10:10.345
· 学生的标记为s，工人的标记为w
· 生成的ID号：学生 --> s20090322201010345023
工人 --> w20090322201010345023
因为现在的程序要满足文件和数据库的操作标准，所以此处应该定义出一个公共的标准 —— 接口
查询信息的时候可以进行排序操作，可以使用Comparable接口完成。

整个代码中牵扯到数据层的操作
· 数据层就是指真实的数据操作 --> CRUD。
· 最终结果操作的肯定是一个人（人为工人和学生）
应该进行分开，一个是全部的学生管理，一个是全部的工人管理。
数据层操作标准定义完成之后，有两种选择，一种是直接使用子类实现，但是以后的修改不是很方便，
所以此处最好使用代理设计的思路完成，做一个中间层。
代码关系：
Main --> Menu --> PersonOperate --> DAO

因为程序即要求使用文件保存，又要求使用数据库保存，所以此处可以设计出一个工厂，通过此工厂进行DAO的操作子类实例取得。

在之前程序的基础上加入数据库的功能，现在不使用文件保存了，而使用数据库进行保存。
如果现在要是把一个完整的PersonDAO接口分为StudentDAO和WorkerDAO两个接口，则调用处就不用修改代码。

数据库使用的是mysql，所以需要单独安装一个数据库的驱动程序

##################Michael分割线##########################

PersonDAO.java

package org.michael.demo.dao;
import java.util.Set;
import org.michael.demo.vo.Person;
// 定义具体的数据的操作方法
public interface PersonDAO {
         /**
         * 插入数据的操作
         *
         * @param person
         *                        插入的是一个人员信息
         * @return 操作成功与否的提示
         * @throws Exception
         *                         如果有错误，则把错误抛给调用处处理
         */
         public boolean doCreate(Person person) throws Exception;
         /**
         * 更新数据操作
         *
         * @param person
         *                        更新的具体信息
         * @return 更新成功与否的提示
         * @throws Exception
         *                         如果有错误，则把错误抛出
         */
         public boolean doUpdate(Person person) throws Exception;
         /**
         * 按id删除信息
         *
         * @param id
         *                        人员的编号
         * @return 删除与否的提示
         * @throws Exception
         *                         如果有错误，则在调用处处理
         */
         public boolean doDelete(String id) throws Exception;
         /**
         * 因为查询是多个，所以要返回Set集合
         *
         * @return 全部的查询结果，一个Set中包含了多个Person对象
         * @throws Exception
         */
         public Set<Person> findAll() throws Exception;
         /**
         * 按id进行查询
         *
         * @param id
         *                        人员的编号
         * @return 具体的人员信息
         * @throws Exception
         */
         public Person findById(String id) throws Exception;
         /**
         * 按关键字进行查询
         *
         * @param keyWord
         *                        输入的关键字
         * @return 返回一组信息
         * @throws Exception
         */
         public Set<Person> findByLike(String keyWord) throws Exception;
}

PersonDAOImplJDBC.java

package org.michael.demo.dao.impl;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Set;
import java.util.TreeSet;
import org.michael.demo.dao.PersonDAO;
import org.michael.demo.dbc.DataBaseConnection;
import org.michael.demo.vo.Person;
import org.michael.demo.vo.Student;
import org.michael.demo.vo.Worker;
public class PersonDAOImplJDBC implements PersonDAO {
         private DataBaseConnection dbc = null;
         private String type = null;
         // 查询操作分为两点，要么是查询工人，要么是查询学生
         public PersonDAOImplJDBC(String type) {
                 this();
                 this.type = type;
        }
         public PersonDAOImplJDBC() {
        }
         public boolean doCreate(Person person) throws Exception {
                 this.dbc = new DataBaseConnection();
                 boolean flag = false;
                 try {
                        PreparedStatement pstmt = null;
                         // 如果传入的是学生，则type为0，如果传入的是工人，则type为1
                        String sql = null;
                         float temp = 0.0f;
                         if (person instanceof Student) {
                                Student stu = (Student) person;
                                temp = stu.getScore();
                                sql = "INSERT INTO tperson(id,name,age,score,type) VALUES (?,?,?,?,0)";
                        }
                         if (person instanceof Worker) {
                                Worker wor = (Worker) person;
                                temp = wor.getSalary();
                                sql = "INSERT INTO tperson(id,name,age,salary,type) VALUES (?,?,?,?,1)";
                        }
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, person.getId());
                        pstmt.setString(2, person.getName());
                        pstmt.setInt(3, person.getAge());
                        pstmt.setFloat(4, temp);
                        pstmt.executeUpdate();
                        pstmt.close();
                        flag = true;
                } catch (Exception e) {
                         throw e;
                } finally {
                         // 最终无论是否发生异常，都必须关闭数据库
                         this.dbc.close();
                }
                 return flag;
        }
         public boolean doDelete(String id) throws Exception {
                 this.dbc = new DataBaseConnection();
                 boolean flag = false;
                 try {
                        PreparedStatement pstmt = null;
                         // 如果传入的是学生，则type为0，如果传入的是工人，则type为1
                        String sql = null;
                        sql = "DELETE FROM tperson WHERE id=?";
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, id);
                        pstmt.executeUpdate();
                        pstmt.close();
                        flag = true;
                } catch (Exception e) {
                         throw e;
                } finally {
                         // 最终无论是否发生异常，都必须关闭数据库
                         this.dbc.close();
                }
                 return flag;
        }
         public boolean doUpdate(Person person) throws Exception {
                 this.dbc = new DataBaseConnection();
                 boolean flag = false;
                 try {
                        PreparedStatement pstmt = null;
                         // 如果传入的是学生，则type为0，如果传入的是工人，则type为1
                        String sql = null;
                         float temp = 0.0f;
                         if (person instanceof Student) {
                                Student stu = (Student) person;
                                temp = stu.getScore();
                                sql = "UPDATE tperson SET name=?,age=?,score=? WHERE id=?";
                        }
                         if (person instanceof Worker) {
                                Worker wor = (Worker) person;
                                temp = wor.getSalary();
                                sql = "UPDATE tperson SET name=?,age=?,salary=? WHERE id=?";
                        }
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, person.getName());
                        pstmt.setInt(2, person.getAge());
                        pstmt.setFloat(3, temp);
                        pstmt.setString(4, person.getId());
                        pstmt.executeUpdate();
                        pstmt.close();
                        flag = true;
                } catch (Exception e) {
                         throw e;
                } finally {
                         // 最终无论是否发生异常，都必须关闭数据库
                         this.dbc.close();
                }
                 return flag;
        }
         public Set<Person> findAll() throws Exception {
                 this.dbc = new DataBaseConnection();
                Set<Person> newSet = new TreeSet<Person>();
                String sql = null;
                 if ( "0".equals( this.type)) {
                        sql = "SELECT id,name,age,score FROM tperson WHERE type=?";
                }
                 if ( "1".equals( this.type)) {
                        sql = "SELECT id,name,age,salary FROM tperson WHERE type=?";
                }
                PreparedStatement pstmt = null;
                 try {
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, this.type);
                        ResultSet rs = pstmt.executeQuery();
                         while (rs.next()) {
                                 // 要进行判断，判断是实例化Student还是实例化Worker
                                 if ( "0".equals( this.type)) {
                                        newSet.add( new Student(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4)));
                                }
                                 if ( "1".equals( this.type)) {
                                        newSet.add( new Worker(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4)));
                                }
                        }
                        rs.close();
                        pstmt.close();
                } catch (Exception e) {
                         throw e;
                } finally {
                         this.dbc.close();
                }
                 return newSet;
        }
         public Person findById(String id) throws Exception {
                 this.dbc = new DataBaseConnection();
                Person person = null;
                String sql = null;
                 if ( "0".equals( this.type)) {
                        sql = "SELECT id,name,age,score FROM tperson WHERE id=?";
                }
                 if ( "1".equals( this.type)) {
                        sql = "SELECT id,name,age,salary FROM tperson WHERE id=?";
                }
                PreparedStatement pstmt = null;
                 try {
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, id);
                        ResultSet rs = pstmt.executeQuery();
                         while (rs.next()) {
                                 // 要进行判断，判断是实例化Student还是实例化Worker
                                 if ( "0".equals( this.type)) {
                                        person = new Student(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4));
                                }
                                 if ( "1".equals( this.type)) {
                                        person = new Worker(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4));
                                }
                        }
                        rs.close();
                        pstmt.close();
                } catch (Exception e) {
                         throw e;
                } finally {
                         this.dbc.close();
                }
                 return person;
        }
         public Set<Person> findByLike(String keyWord) throws Exception {
                 this.dbc = new DataBaseConnection();
                Set<Person> newSet = new TreeSet<Person>();
                String sql = null;
                sql = "SELECT id,name,age,score FROM tperson WHERE type=? AND name LIKE ?";
                PreparedStatement pstmt = null;
                 try {
                        pstmt = this.dbc.getConnection().prepareStatement(sql);
                        pstmt.setString(1, this.type);
                        pstmt.setString(2, "%" + keyWord + "%");
                        ResultSet rs = pstmt.executeQuery();
                         while (rs.next()) {
                                 // 要进行判断，判断是实例化Student还是实例化Worker
                                 if ( "0".equals( this.type)) {
                                        newSet.add( new Student(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4)));
                                }
                                 if ( "1".equals( this.type)) {
                                        newSet.add( new Worker(rs.getString(1), rs.getString(2), rs
                                                        .getInt(3), rs.getFloat(4)));
                                }
                        }
                        rs.close();
                        pstmt.close();
                } catch (Exception e) {
                         throw e;
                } finally {
                         this.dbc.close();
                }
                 return newSet;
        }
}

DataBaseConnection.java

package org.michael.demo.dbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
//数据库的连接操作类
public class DataBaseConnection {
         private static final String DBDRIVER = "org.gjt.mm.mysql.Driver";
         private static final String DBURL = "jdbc:mysql://localhost:3306/51cto";
        private static final String DBUSER = "root";
        private static final String DBPASSWORD = "mysqladmin";
        private Connection conn = null;
        public DataBaseConnection() {
                try {
                        Class.forName(DBDRIVER);
                } catch (ClassNotFoundException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                try {
                        this.conn = DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD);
                } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
        public Connection getConnection() {
                return this.conn;
        }
        public void close(){
                try {
                        this.conn.close() ;
                } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }
}

数据库创建脚本

DROP TABLE tperson ;
CREATE TABLE tperson
(
        id         VARCHAR(50)         PRIMARY KEY NOT NULL ,
         name         VARCHAR(50)         NOT NULL ,
        age         INT                 NOT NULL ,
        score         FLOAT ,
        salary         FLOAT ,
        type         INT     NOT NULL DEFAULT 0
) ;
-- 如果type的值为0，则表示学生，如果type的值为1则表示工人。

DAOFactory.java

package org.michael.demo.factory;
import org.michael.demo.dao.PersonDAO;
import org.michael.demo.proxy.PersonDAOProxyJDBC;
public class DAOFactory {
         public static PersonDAO getPersonDAOInstance(String path) {
                 return new PersonDAOProxyJDBC(path);
        }
}

FileOperate.java

package org.michael.demo.io;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.TreeSet;
import org.michael.demo.vo.Person;
public class FileOperate {
         private File file = null;
         // 在够方法处必须指定保存文件的名字
         public FileOperate(String path) {
                 this.file = new File(path);
                 if (! this.file.exists()) {
                         // 如果内容不存在，则认为是第一次操作，需要初始化
                         try {
                                 this.save( new TreeSet<Person>()) ;
                        } catch (Exception e) {
                                e.printStackTrace();
                        }
                }
        }
         // 把对象保存在文件之中
         public void save(Object obj) throws Exception {
                ObjectOutputStream out = null;
                 try {
                        out = new ObjectOutputStream( new FileOutputStream( this.file));
                         // 写入对象
                        out.writeObject(obj);
                } catch (Exception e) {
                         throw e;
                } finally {
                         try {
                                out.close();
                        } catch (Exception e) {
                        }
                }
        }
         // 把对象从文件之中读进来
         public Object load() throws Exception {
                Object obj = null;
                ObjectInputStream input = null;
                 try {
                        input = new ObjectInputStream( new FileInputStream( this.file));
                        obj = input.readObject();
                } catch (Exception e) {
                         throw e;
                } finally {
                         try {
                                input.close();
                        } catch (Exception e) {
                        }
                }
                 return obj;
        }
}

Main.java

package org.michael.demo.main;
import org.michael.demo.menu.Menu;
public class Main {
         public static void main(String[] args) {
                 new Menu();
        }
}

#################Michael分割线####################

[零基础学JAVA]Java SE实战开发-37.MIS信息管理系统实战开发[JDBC](2)

[零基础学JAVA]Java SE实战开发-37.MIS信息管理系统实战开发[JDBC](3)

#################Michael分割线####################

源代码下载

#################Michael分割线####################

本文转自redking51CTO博客，原文链接：http://blog.51cto.com/redking/145367 ，如需转载请自行联系原作者