Java操作SqlServer增刪改查實踐

更新時間：2026年05月15日 10:53:54 作者：DaNiu.Svip

文章主要講述了在JDK 1 1.8環(huán)境下使用Idea開發(fā)Java程序進行SqlServer數(shù)據(jù)庫的增刪改查操作,主要內容包括環(huán)境搭建、數(shù)據(jù)庫連接配置、SQL語句編寫及操作實現(xiàn)等

Java操作SqlServer增刪改查

環(huán)境

jdk1.8下

開發(fā)軟件

idea

import java.sql.*;

public class Demo1 {
    //驅動路徑
    private static final String DBDRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    //數(shù)據(jù)庫地址
    private static final String DBURL = "jdbc:sqlserver://192.168.12.110";
    //數(shù)據(jù)庫登陸名
    private static final String DBUSER = "WSZ";
    //數(shù)據(jù)庫登陸用戶密碼
    private static final String DBPASSWORD = "WSZ";
    //數(shù)據(jù)庫連接
    public static Connection conn = null;
    //數(shù)據(jù)庫操作
    public static Statement stmt = null;
    //數(shù)據(jù)庫查詢結果集
    public static ResultSet rs = null;

    public static void main(String[] args) {
        //調用connectDatabase()方法來連接數(shù)據(jù)庫
//        connectDatabase();
        //調用search()方法來查詢
        search();
        //調用add()方法來增加
//        add();
        //調用update()方法來修改
//        update();
        //調用delete()方法來刪除
//        delete();


    }

    public static Connection connectDatabase(){
        /**
         * 連接數(shù)據(jù)庫
         */
        try {

            //加載驅動程序
            Class.forName(DBDRIVER);
            //連接數(shù)據(jù)庫
            conn = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD);
            System.out.println("數(shù)據(jù)庫連接成功" );
            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();
                }
            }
        }
    }



}