增刪改查-java（新手）

 PreparedStatement:

方法：

 

 

---

Connection：

方法：

 

---

 實例：

---

 

1、查詢：

package cn.chuang.JdbcDome;

import java.sql.*;

public class JdbcDome3 {
    public static void main(String[] args) throws Exception {
        PreparedStatement ppst = null;
        Connection conn = null;
        fun3(ppst,conn);
    }

    public static void fun1(PreparedStatement ppst,Connection conn) throws Exception {
        //查詢表的內容
        //1 注冊驅動 獲得Connection
        Class.forName("com.mysql.jdbc.Driver");
        //2 獲得鏈接
        conn = DriverManager.getConnection("jdbc:mysql:///semployee", "root", "root");
        //3 sql語句
        String sql = "select * from lll";
        //4 獲得執行sql語句的對象
        ppst = conn.prepareStatement(sql);
        ResultSet rs = ppst.executeQuery(sql);
        //5 讓游標向下移動一行
        rs.next();
        int i = rs.getInt(1);
        String name = rs.getString("ename");
        //6 獲取數據
        System.out.println(i+"  "+name);
    }
   

 

---

 

2、添加

    public static void fun2(PreparedStatement ppst,Connection conn) throws Exception {
        //在表中添加數據，表結構有多少就要寫多少。不能漏寫，會報錯。
        try {
            //1 注冊驅動 獲得Connection
            Class.forName("com.mysql.jdbc.Driver");
            //2 獲得鏈接
            conn = DriverManager.getConnection("Jdbc:mysql:///semployee", "root", "root");

            //3 sql語句
            String sql = "insert into lll values (null,'兀立扗'),(null,'吳詩意')";
            //4 獲得執行sql語句的對象
            ppst = conn.prepareStatement(sql);
            int i = ppst.executeUpdate(sql);
            //5 處理結果
            System.out.println(i);
            //6 另創建if語句，做提示用。
            if (i>0){
                System.out.println("添加成功");
            }else{
                System.out.println("添加失敗");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            if(ppst!=null){
                try {
                    ppst.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
   

 

---

 

3、刪除 

 public static void fun3(PreparedStatement ppst,Connection conn) throws Exception {
        //刪除表內數據。
        //1 注冊驅動 獲得Connection
        Class.forName("com.mysql.jdbc.Driver");
        conn = DriverManager.getConnection("jdbc:mysql:///semployee", "root", "root");
        //2 sql語句
        String sql = "delete from lll where uid = 2";
        //3 獲得執行sql語句的對象Statement
        ppst = conn.prepareStatement(sql);
        int i = ppst.executeUpdate(sql);
        //4 處理結果
        System.out.println(i);

        if (i>0){
            System.out.println("刪除成功");
            ppst.close();
            conn.close();
        }else{
            System.out.println("刪除失敗");
        }
    }

 

---

 4、修改

public static void fun4(PreparedStatement ppst,Connection conn) throws Exception {
　　　　　　//修改表內數據
        //1 注冊驅動。
        Class.forName("com.mysql.jdbc.Driver");
        //2 鏈接數據庫。
        conn = DriverManager.getConnection("jdbc:mysql:///semployee", "root", "root");

        //3 SQL語句。
        String sql = "update lll set  uname = '吳惆' where uid = 1  ";

        //4 獲得執行SQL的語句。
        ppst = conn.prepareStatement(sql);
        //5 處理結果。
        int ou = ppst.executeUpdate(sql);
        System.out.println(ou);
    }
}