JDBC 24homework

编写程序：

1. 创建商品信息表Goods（包含编号Code、名称Name、数量Number、单价Price）

2. 设计程序流程，由用户选择：插入、删除、修改、查询

程序效果如下：

（1）根据提示输入：1.插入 2.删除 3.修改 4.查询

（2）如果用户选择1. 则提示用户输入商品的编号、名称、数量、单价信息，并将用户输入的数据insert到表中。

（3）如果用户选择2，则表示用户要删除一个商品，提示用户输入商品编号，并根据用户输入的编号删除表中的记录。

（4）自行设计修改的实现方法

（5）自行设计查询的方法

 

package com.xt.java.base24;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

public class UserTest {

    public static void main(String[] args) {
        while(true){
        Scanner scanner=new Scanner(System.in);
        System.out.println("----------------欢迎进入商品管理系统-------------------");
        System.out.println("插入----------1");
        System.out.println("删除----------2");
        System.out.println("修改----------3");
        System.out.println("查询----------4");
        System.out.println("退出----------0

");
        System.out.println("请选择您要进行的操作：");
        int selectNum=scanner.nextInt();
        Connection conn=null;
        Statement stat=null;
        ResultSet rs=null;
        String url="jdbc:mysql://localhost:3306/lyxdatabases";
        
        //加载驱动，通过驱动管理器将Java与数据库建立联系。同时排除异常。
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn=DriverManager.getConnection(url,"root","1234");
            stat=conn.createStatement();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
        
        switch(selectNum){
        case 0:{
            System.out.println("退出系统！！！");
            System .exit(0);
            break;
        }
        case 1:{
            System.out.println("请输入您要插入的商品的编号：");
            int gCode=scanner.nextInt();
            System.out.println("请输入您要插入的商品的名称：");
            String gName=scanner.next();
            System.out.println("请输入您要插入的商品的数量：");
            int gNumber=scanner.nextInt();
            System.out.println("请输入您要插入的商品的价钱：");
            double gPrice=scanner.nextDouble();
            String sql="insert into goodsTwo values("+gCode+",'"+gName+"',"+gNumber+","+gPrice+")";
            //查看sql语句是否输入正确！
            System.out.println(sql);
            try {
                int affectedRows=stat.executeUpdate(sql);
                if(affectedRows>0){
                    System.out.println("商品插入成功！");
                }else{
                    System.out.println("商品插入失败，请重新操作。。。。。。");
                }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                if(rs!=null){
                rs.close();
                }
                if(stat!=null){
                    stat.close();
                }
                if(conn!=null){
                    conn.close();
                }
            }
             catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
             
            }
            break;
        }
        case 2:{
            System.out.println("请输入您要删除的商品的编号：");
            int gCode1=scanner.nextInt();
            String sql1="delete from goodsTwo where code="+gCode1;
            try {
                int affectedRows1=stat.executeUpdate(sql1);
                if(affectedRows1>0){
                    System.out.println("商品删除成功！！");
                }else{
                    System.out.println("商品删除失败，请重新操作。。。。。。");
                }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                if(rs!=null){
                rs.close();
                }
                if(stat!=null){
                    stat.close();
                }
                if(conn!=null){
                    conn.close();
                }
            }
             catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
             
            }
            break;
        }
        case 3:{
            while (true){
            System.out.println("请输入您要改正的商品的编号：");
            int gCode2=scanner.nextInt();
            System.out.println("编号----------a");
            System.out.println("名称----------b");
            System.out.println("数量----------c");
            System.out.println("价钱----------d");
            System.out.println("操作完成，退出系统----------e");
            
            System.out.println("----------请选择您要改正的对象：");
            String mark=scanner.next();
            /**
             * 改正编号。。。
             */
            if(mark.equals("a")){
                System.out.println("请输入你要改正的编号：");
                int code2=scanner.nextInt();
                String sql2="update goodsTwo set code="+code2+" where code="+gCode2;
                //查看sql2语句是否输入正确！
                System.out.println(sql2);
                
                try {
                    int affectedRows1=stat.executeUpdate(sql2);
                    if(affectedRows1>0){
                        System.out.println("商品改正成功！！");
                    }else{
                        System.out.println("商品改正失败，请重新操作。。。。。。");
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            
            }
            
            /**
             * 改正名称。。。。
             */
            else if(mark.equals("b")){
                System.out.println("请输入你要改正的名称：");
                String gName=scanner.next();
                String sql3="update goodsTwo set name='"+gName+"' where code="+gCode2;
                //查看sql3语句是否输入正确！
                System.out.println(sql3);
                
                try {
                    int affectedRows1=stat.executeUpdate(sql3);
                    if(affectedRows1>0){
                        System.out.println("商品改正成功！！");
                    }else{
                        System.out.println("商品改正失败，请重新操作。。。。。。");
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            
            }
            /**
             * 改正数量。。。。
             */
            else if(mark.equals("c")){
                System.out.println("请输入你要改正的数量：");
                int gNumber=scanner.nextInt();
                String sql4="update goodsTwo set number="+gNumber+" where code="+gCode2;
                //查看sql4语句是否输入正确！
                System.out.println(sql4);
                
                try {
                    int affectedRows1=stat.executeUpdate(sql4);
                    if(affectedRows1>0){
                        System.out.println("商品改正成功！！");
                    }else{
                        System.out.println("商品改正失败，请重新操作。。。。。。");
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                try {
                    if(rs!=null){
                    rs.close();
                    }
                    if(stat!=null){
                        stat.close();
                    }
                    if(conn!=null){
                        conn.close();
                    }
                }
                 catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                 
                }
            
            }
            /**
             * 改正价钱。。。
             */
            else if(mark.equals("d")){
                System.out.println("请输入你要改正的价钱：");
                double gPrice2=scanner.nextDouble();
                String sql4="update goodsTwo set price="+gPrice2+" where code="+gCode2;
                //查看sql4语句是否输入正确！
                System.out.println(sql4);
                
                try {
                    int affectedRows1=stat.executeUpdate(sql4);
                    if(affectedRows1>0){
                        System.out.println("商品改正成功！！");
                    }else{
                        System.out.println("商品改正失败，请重新操作。。。。。。");
                    }
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            
            }
            else if(mark.equals("e")){
                System.out.println("操作完成，退出系统!!");
                return;
            }
            else{
                System.out.println("您输入的数据有错误，请重新输入！！！");
                break;
            }
            
            
        }
            
        }
        case 4:{
            System.out.println("请输入您要查询的商品的编号：");
            int gCode5=scanner.nextInt();
            String sql5="select* from goodsTwo where code="+gCode5;
            try {
                rs=stat.executeQuery(sql5);
                while(rs.next()){
                System.out.print("编号："+rs.getInt("code")+"    ");
                System.out.print("名称："+rs.getString("name")+"   ");
                System.out.print("数量："+rs.getInt("number")+"   ");
                System.out.println("价钱："+rs.getDouble("price"));}
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        
        
        }
        
        try {
            if(rs!=null){
            rs.close();
            }
            if(stat!=null){
                stat.close();
            }
            if(conn!=null){
                conn.close();
            }
        }
         catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
         
        }
        break;
        }
        
        
        }
        
    }

}