JAVA-使用MyEclipse连接MySQL进行增删改查操作

前言

　　在笔者学习搭建WEB项目的时候，遇到过不少问题，如连接驱动失败，连接数据库失败，通过SQL操作数据库失败等等。

　　  今天就做个笔记，关于如何通过JDBC连接MySQL，以及如何在MyEclipse中操作数据库进行增、删、改、查的操作。

 

相关链接

　　　连接MySQL的jar包（链接：https://pan.baidu.com/s/1i7ckX4D    密码：3rwt）

 

代码片段

工具类（函数①连接驱动、获取Connection；函数②关闭Connection）

 

package com.sariel.Utils;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import com.mysql.jdbc.Connection;

public class DBUtils {
    private final static String driverName="com.mysql.jdbc.Driver";
    private final static String url="jdbc:mysql://localhost:3306/sariel_db";
    private final static String user="root";
    private final static String pwd="sariel";
    
    /** 连接Mysql数据库*/
    public static Connection getCon(){
        Connection conn=null;
        try {
            Class.forName(driverName);
            System.out.println("加载驱动成功");
            conn = (Connection) DriverManager.getConnection(url, user, pwd);
            System.out.println("数据库连接成功");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("数据库连接失败");
        }
        return conn;
    }
    
    
    /** 断开Mysql数据库*/
    public static void closeCon(Connection conn, PreparedStatement stat, ResultSet rs){
        try {
            if(rs!=null){
                rs.close();
            }if(stat!=null){
                stat.close();
            }if(conn!=null){
                conn.close();
            }
            System.out.println("已断开数据库连接");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 

 

 

实体类 （客户资料表）

package com.sariel.Bean;

/** 客户资料 */
public class Customer_Information {
    /** sysID */
    private String sys_id;
    /** cusID */
    private String cus_id;

    /** 账号 */
    private String cus_account_number;

    /** 性别 */
    private String cus_sex;

    /** 个性签名 */
    private String cus_personality_signature;

    /** 兴趣爱好 */
    private String cus_hobby;

    /** 密码 */
    private String cus_psssworld;

    /** 邮箱 */
    private String cus_email;

    /** 电话 */
    private String cus_phone_number;

    /** 地址 */
    private String cus_address;

    /** 头像路径 */
    private String cus_head_portrait;

    /** 无参构造方法 */
    public Customer_Information() {
        super();
    }

    /** 有参构造方法 */
    public Customer_Information(String sysId, String cusId,
            String cusAccountNumber, String cusSex,
            String cusPersonalitySignature, String cusHobby,
            String cusPsssworld, String cusEmail, String cusPhoneNumber,
            String cusAddress, String cusHeadPortrait) {
        super();
        sys_id = sysId;
        cus_id = cusId;
        cus_account_number = cusAccountNumber;
        cus_sex = cusSex;
        cus_personality_signature = cusPersonalitySignature;
        cus_hobby = cusHobby;
        cus_psssworld = cusPsssworld;
        cus_email = cusEmail;
        cus_phone_number = cusPhoneNumber;
        cus_address = cusAddress;
        cus_head_portrait = cusHeadPortrait;
    }

    public String getSys_id() {
        return sys_id;
    }

    public void setSys_id(String sysId) {
        sys_id = sysId;
    }

    public String getCus_id() {
        return cus_id;
    }

    public void setCus_id(String cusId) {
        cus_id = cusId;
    }

    public String getCus_account_number() {
        return cus_account_number;
    }

    public void setCus_account_number(String cusAccountNumber) {
        cus_account_number = cusAccountNumber;
    }

    public String getCus_sex() {
        return cus_sex;
    }

    public void setCus_sex(String cusSex) {
        cus_sex = cusSex;
    }

    public String getCus_personality_signature() {
        return cus_personality_signature;
    }

    public void setCus_personality_signature(String cusPersonalitySignature) {
        cus_personality_signature = cusPersonalitySignature;
    }

    public String getCus_hobby() {
        return cus_hobby;
    }

    public void setCus_hobby(String cusHobby) {
        cus_hobby = cusHobby;
    }

    public String getCus_psssworld() {
        return cus_psssworld;
    }

    public void setCus_psssworld(String cusPsssworld) {
        cus_psssworld = cusPsssworld;
    }

    public String getCus_email() {
        return cus_email;
    }

    public void setCus_email(String cusEmail) {
        cus_email = cusEmail;
    }

    public String getCus_phone_number() {
        return cus_phone_number;
    }

    public void setCus_phone_number(String cusPhoneNumber) {
        cus_phone_number = cusPhoneNumber;
    }

    public String getCus_address() {
        return cus_address;
    }

    public void setCus_address(String cusAddress) {
        cus_address = cusAddress;
    }

    public String getCus_head_portrait() {
        return cus_head_portrait;
    }

    public void setCus_head_portrait(String cusHeadPortrait) {
        cus_head_portrait = cusHeadPortrait;
    }
}

 

逻辑类(实现对客户资料的增删改查操作)

package com.sariel.Service;

import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
import com.sariel.Bean.Customer_Information;
import com.sariel.Utils.DBUtils;

/** 客户信息逻辑 */
public class Customer_Information_Service {

    public static void main(String[] args) {
//        Customer_Information_Service cs = new Customer_Information_Service();
//        cs.selectCustomerInfoById("YXG001");// 根据客户的cus_id查询指定客户资料信息
    }

    /** 新增客户信息 */
    public boolean addCustomerInfo(String cus_id, String cus_account_number,
            String cus_sex, String cus_personality_signature, String cus_hobby,
            String cus_psssworld, String cus_email, String cus_phone_number,
            String cus_address, String cus_head_portrait) {
        boolean flag = false;
        Connection conn = null;
        PreparedStatement pstmt = null;
        String sql = "insert into customer_information value(null,?,?,?,?,?,?,?,?,?,?)";
        try {
            if (addEmpty(cus_id, cus_account_number, cus_sex,
                    cus_personality_signature, cus_hobby, cus_psssworld,
                    cus_email, cus_phone_number, cus_address, cus_head_portrait)) {
                conn = DBUtils.getCon();
                pstmt = (PreparedStatement) conn.prepareStatement(sql);
                pstmt.setString(1, cus_id);
                pstmt.setString(2, cus_account_number);
                pstmt.setString(3, cus_sex);
                pstmt.setString(4, cus_personality_signature);
                pstmt.setString(5, cus_hobby);
                pstmt.setString(6, cus_psssworld);
                pstmt.setString(7, cus_email);
                pstmt.setString(8, cus_phone_number);
                pstmt.setString(9, cus_address);
                pstmt.setString(10, cus_head_portrait);

                int num = pstmt.executeUpdate();
                if (num > 0) {
                    System.out.println("新增数据成功");
                } else {
                    System.out.println("新增数据失败");
                }
            } else {
                System.out.println("新增客户信息时，有必输项为空，新增失败");
            }

        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("新增出现异常");
        } finally {
            DBUtils.closeCon(conn, pstmt, null);
        }
        return flag;
    }

    /** 按账号修改客户信息 */
    public boolean updateCustomerInfo(String cus_id, String cus_account_number,
            String cus_sex, String cus_personality_signature, String cus_hobby,
            String cus_psssworld, String cus_email, String cus_phone_number,
            String cus_address, String cus_head_portrait) {
        boolean flag = false;
        Connection conn = null;
        PreparedStatement pstmt = null;
        String sql = "update customer_information set cus_account_number=?,cus_sex=?,cus_personality_signature=?,cus_hobby=?,cus_psssworld=?,cus_email=?,cus_phone_number=?,cus_address=?,cus_head_portrait=?,cus_id=? where cus_id = ?";
        try {
            if (cus_id != null || !"".equals(cus_id)) {
                Customer_Information oldInfo = selectCustomerInfoById(cus_id);
                if (cus_id == null || "".equals(cus_id)) {
                    cus_id = oldInfo.getCus_account_number();
                }
                if (cus_account_number == null || "".equals(cus_account_number)) {
                    cus_account_number = oldInfo.getCus_account_number();
                }
                if (cus_sex == null || "".equals(cus_sex)) {
                    cus_sex = oldInfo.getCus_sex();
                }
                if (cus_personality_signature == null
                        || "".equals(cus_personality_signature)) {
                    cus_personality_signature = oldInfo
                            .getCus_personality_signature();
                }
                if (cus_hobby == null || "".equals(cus_hobby)) {
                    cus_hobby = oldInfo.getCus_hobby();
                }
                if (cus_psssworld == null || "".equals(cus_psssworld)) {
                    cus_psssworld = oldInfo.getCus_psssworld();
                }
                if (cus_email == null || "".equals(cus_email)) {
                    cus_email = oldInfo.getCus_email();
                }
                if (cus_phone_number == null || "".equals(cus_phone_number)) {
                    cus_phone_number = oldInfo.getCus_phone_number();
                }
                if (cus_address == null || "".equals(cus_address)) {
                    cus_address = oldInfo.getCus_address();
                }
                if (cus_head_portrait == null || "".equals(cus_head_portrait)) {
                    cus_head_portrait = oldInfo.getCus_head_portrait();
                }
                conn = DBUtils.getCon();
                pstmt = (PreparedStatement) conn.prepareStatement(sql);
                pstmt.setString(1, cus_account_number);
                pstmt.setString(2, cus_sex);
                pstmt.setString(3, cus_personality_signature);
                pstmt.setString(4, cus_hobby);
                pstmt.setString(5, cus_psssworld);
                pstmt.setString(6, cus_email);
                pstmt.setString(7, cus_phone_number);
                pstmt.setString(8, cus_address);
                pstmt.setString(9, cus_head_portrait);
                pstmt.setString(10, cus_id);
                pstmt.setString(11, cus_id);

                int num = pstmt.executeUpdate();
                if (num > 0) {
                    System.out.println("修改数据成功"
                            + "\n"
                            + selectCustomerInfoById(cus_id)
                                    .getCus_account_number() + "\t"
                            + selectCustomerInfoById(cus_id).getCus_address());
                    flag = true;
                } else {
                    System.out.println("修改数据失败");
                    // flag = false;
                }
            } else {
                System.out.println("[cus_id]客户ID不能为空,数据修改失败");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeCon(conn, pstmt, null);
        }
        return flag;
    }

    /** 删除指定ID的客户信息 */
    public boolean deleteCustomerInfo(String cus_id) {
        boolean flag = false;
        Connection conn = null;
        PreparedStatement pstmt = null;
        String sql = "delete from customer_information where cus_id = ?";
        try {
            if (cus_id != null && !"".equals(cus_id)) {
                conn = DBUtils.getCon();
                pstmt = (PreparedStatement) conn.prepareStatement(sql);
                pstmt.setString(1, cus_id);
                int num = pstmt.executeUpdate();
                if (num > 0) {
                    flag = true;
                    System.out.println("删除指定客户数据成功");
                } else {
                    flag = false;
                    System.out.println("删除指定客户数据失败");
                }
            } else {
                System.out.println("[cus_id]客户ID不能为空,数据删除失败");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeCon(conn, pstmt, null);
        }
        return flag;
    }

    /** 查询所有客户信息 */
    public List<Customer_Information> selectCustomerInfo() {
        List<Customer_Information> list_cus = new ArrayList<Customer_Information>();
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        String sql = "select * from customer_information";
        if (sql != null) {
            try {
                conn = DBUtils.getCon();
                pstmt = (PreparedStatement) conn.prepareStatement(sql);
                rs = pstmt.executeQuery();
                if (rs != null) {
                    System.out.println("进入result数据集写入方法");
                    while (rs.next()) {
                        Customer_Information cus = new Customer_Information();
                        cus.setCus_id(rs.getString(2));
                        cus.setCus_account_number(rs.getString(3));
                        cus.setCus_sex(rs.getString(4));
                        cus.setCus_personality_signature(rs.getString(5));
                        cus.setCus_hobby(rs.getString(6));
                        cus.setCus_psssworld(rs.getString(7));
                        cus.setCus_email(rs.getString(8));
                        cus.setCus_phone_number(rs.getString(9));
                        cus.setCus_address(rs.getString(10));
                        cus.setCus_head_portrait(rs.getString(11));
                        list_cus.add(cus);
                    }
                    System.out.println("将所有客户信息装入List集合后，集合长度是:"
                            + list_cus.size());
                } else {
                    System.out.println("查询的Resultset为空");
                }
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("查询所有客户信息出现异常");
            } finally {
                DBUtils.closeCon(conn, pstmt, rs);
            }
        }
        return list_cus;
    }

    /** 按账号查询指定客户信息 */
    public Customer_Information selectCustomerInfoById(String cus_id) {
        Customer_Information cus = null;
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        String sql = "select * from customer_information where cus_id = ?";
        try {
            conn = DBUtils.getCon();
            pstmt = (PreparedStatement) conn.prepareStatement(sql);
            pstmt.setString(1, cus_id);
            rs = pstmt.executeQuery();
            if (rs != null || !"".equals(rs)) {
                System.out.println("查到指定账号信息");
                while (rs.next()) {
                    cus = new Customer_Information();
                    cus.setCus_id(rs.getString(2));
                    cus.setCus_account_number(rs.getString(3));
                    cus.setCus_sex(rs.getString(4));
                    cus.setCus_personality_signature(rs.getString(5));
                    cus.setCus_hobby(rs.getString(6));
                    cus.setCus_psssworld(rs.getString(7));
                    cus.setCus_email(rs.getString(8));
                    cus.setCus_phone_number(rs.getString(9));
                    cus.setCus_address(rs.getString(10));
                    cus.setCus_head_portrait(rs.getString(11));
                }
            } else {
                System.out.println("未找到指定账号的客户信息");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeCon(conn, pstmt, rs);
        }
        return cus;
    }

    /** 验证输入的客户必输字段的信息数据是否为空 */
    public boolean addEmpty(String cus_id, String cus_account_number,
            String cus_sex, String cus_personality_signature, String cus_hobby,
            String cus_psssworld, String cus_email, String cus_phone_number,
            String cus_address, String cus_head_portrait) {
        boolean flag = false;
        if (cus_id != null || !"".equals(cus_id)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_id]为空");
        }

        if (cus_account_number != null || !"".equals(cus_account_number)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_account_number]为空");
        }

        if (cus_sex != null || !"".equals(cus_sex)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_sex]为空");
        }

        if (cus_personality_signature != null
                || !"".equals(cus_personality_signature)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_personality_signature]为空");
        }

        if (cus_hobby != null || !"".equals(cus_hobby)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_hobby]为空");
        }

        if (cus_psssworld != null || !"".equals(cus_psssworld)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_psssworld]为空");
        }

        if (cus_email != null || !"".equals(cus_email)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_email]为空");
        }

        if (cus_phone_number != null || !"".equals(cus_phone_number)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_phone_number]为空");
        }

        if (cus_address != null || !"".equals(cus_address)) {
            flag = true;
        } else {
            flag = false;
            System.out.println("[cus_address]为空");
        }
        return flag;
    }
}

 

本篇笔记适用于刚学习使用MyEclipse连接MySQL的朋友，大神们请无视  -.-  

---- THE END   

---- By sariel    2018-1-16