Java操作SqlServer增删改查实践

import java.sql.*;

public class Demo1 {
    //驱动路径
    private static final String DBDRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    //数据库地址
    private static final String DBURL = "jdbc:sqlserver://192.168.12.110";
    //数据库登陆名
    private static final String DBUSER = "WSZ";
    //数据库登陆用户密码
    private static final String DBPASSWORD = "WSZ";
    //数据库连接
    public static Connection conn = null;
    //数据库操作
    public static Statement stmt = null;
    //数据库查询结果集
    public static ResultSet rs = null;

    public static void main(String[] args) {
        //调用connectDatabase()方法来连接数据库
//        connectDatabase();
        //调用search()方法来查询
        search();
        //调用add()方法来增加
//        add();
        //调用update()方法来修改
//        update();
        //调用delete()方法来删除
//        delete();


    }

    public static Connection connectDatabase(){
        /**
         * 连接数据库
         */
        try {

            //加载驱动程序
            Class.forName(DBDRIVER);
            //连接数据库
            conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD);
            System.out.println("数据库连接成功" );
            return conn;

        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    /**
     * 查询
     */
    public static void search(){
        conn = connectDatabase();
        if(null!=conn){
            try{
                //实例化Statement
                stmt = conn.createStatement();
                //查询
                rs = stmt.executeQuery("select * from His_SheetWorkOrder");
                System.out.println("查询出该表信息如下：");
                System.out.println("\t\t日期\t\t\t\t工单号\t\t物料代码\t\t\t品名\t\t\t材料\t\t长度\t\t\t宽度\t\t\t公司\t\t\t机器");
                while (rs.next()){
                    String sq=rs.getString("Sheet_rq");
                    sq+="\t"+rs.getString("Sheet_WorkOrder");
                    sq+="\t\t"+rs.getString("Sheet_ItemCode");
                    sq+="\t\t\t"+rs.getString("Sheet_ItemName");
                    sq+="\t\t\t"+rs.getString("Sheet_Material");
                    sq+="\t\t\t"+rs.getString("Sheet_Thick");
                    sq+="\t\t\t"+rs.getString("Sheet_Width");
                    sq+="\t\t\t"+rs.getString("Sheet_Company");
                    sq+="\t\t\t"+rs.getString("Device_Number");

                    System.out.println(sq);
                }
                stmt.close();
                conn.close();
            }catch (SQLException e){
                e.printStackTrace();
            }

        }
    }

    /**
     * 新增
     */
    public static void add(){
        conn = connectDatabase();
        if (null!=conn){
            try {
                //实例化Statement对象
                stmt = conn.createStatement();
                //新增
                stmt.executeUpdate("INSERT INTO His_SheetWorkOrder VALUES ('2022-09-15 11:40:00','20220915001','C2324','塑材','cxl','10','8','格来纳','1cx')");
                System.out.println("添加成功");
            }catch (SQLException e){
                e.printStackTrace();
            }finally {
                try {
                    stmt.close();
                    conn.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 修改
     */
    public static void update(){
        conn = connectDatabase();
        if(null!=conn){
            try {
                //实例化statement对象
                stmt = conn.createStatement();
                //修改
                stmt.executeUpdate("update His_SheetWorkOrder set Sheet_Width = 18 where Sheet_ItemName='塑材'");
                System.out.println("修改成功");
            }catch (SQLException e){
                e.printStackTrace();
            }finally {
                try {
                    stmt.close();
                    conn.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
        }
    }

    /**
     * 删除
     */
    public static void delete(){
        conn = connectDatabase();
        if (null!=conn){
            try {
                //实例化statement对象
                stmt = conn.createStatement();
                //删除
                stmt.executeUpdate("delete from His_SheetWorkOrder where Sheet_ItemName='塑材'");
                System.out.println("删除成功");
            }catch (SQLException e){
                e.printStackTrace();
            }finally {
                try {
                    stmt.close();
                    conn.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
        }
    }



}