在IDEA中連接到MySQL

本文轉載自查看原文 2020-12-17 11:10 504 Mysql

JDBC（重點）

數據庫驅動

我們的程序會通過數據庫驅動，和數據庫打交道！

就會通過數據庫驅動與數據庫相關聯

JDBC

SUN公司為了簡化開發人員的（對數據庫的統一）操作，提供了一個（Java操作數據庫的）規范，俗稱：JDBC

這些規范的實現由具體的廠商去做。

對於開發人員來說，我們只需要

java.sql

javax.sql

還需要導入一個數據庫驅動包

第一個JDBC程序

創建測試數據庫

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;
1. 
USE jdbcStudy;

CREATE TABLE `users`(
	id INT PRIMARY KEY,
	NAME VARCHAR(40),
	PASSWORD VARCHAR(40),
	email VARCHAR(60),
	birthday DATE
);

INSERT INTO `users`(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhansan','123456','zs@sina.com','1980-12-04'),
(2,'lisi','123456','lisi@sina.com','1981-12-04'),
(3,'wangwu','123456','wangwu@sina.com','1979-12-04')

創建一個普通項目
導入數據庫驅動（創建一個lib文件夾導入jar文件-->右鍵文件Add as Library）
編寫測試代碼

package lijinyu.lesson01;

import java.sql.*;

//我的第一個JDBC程序
public class JdbcFirstDemo {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1 加載驅動
        Class.forName("com.mysql.jdbc.Driver");  //固定寫法 加載驅動
        //2. 用戶信息和url
        //useUnicode=true&characterEncoding=utf8&useSSL=true 
        String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&&characterEncoding=utf8&&useSSL=false";
        String username="root";
        String password="ljy123456";
        // 3.連接成功，數據庫對象  connection  代表數據庫
        Connection connection = DriverManager.getConnection(url, username, password);
        //4. 執行SQL的對象  Statement  執行SQL的對象
        Statement statement = connection.createStatement();
        // 5. 執行SQL的對象  去 執行SQL ，可能存在結果 ，查看返回結果
        String  sql="SELECT * FROM `users`";
        ResultSet resultSet = statement.executeQuery(sql);  // 返回的結果集,結果集中封裝了我們全部的查詢出來的結果

        while (resultSet.next()){
            System.out.println("id="+ resultSet.getObject("id"));
            System.out.println("name="+ resultSet.getObject("NAME"));
            System.out.println("pwd="+ resultSet.getObject("PASSWORD"));
            System.out.println("email="+ resultSet.getObject("email"));
            System.out.println("birth="+ resultSet.getObject("birthday"));
        }
        // 6. 釋放連接
        resultSet.close();
        statement.close();
        connection.close();

    }
}

步驟總結：

加載驅動
連接數據庫DriverManager
獲得執行sql的對象 Statement
獲得返回的結果集
釋放連接

DriverManager

  Class.forName("com.mysql.jdbc.Driver");
    Connection connection = DriverManager.getConnection(url, username, password);

//connection 代表數據庫
// 數據庫設置自動提交
//事務提交
//事務回滾
connection.rollback();
connection.commit();
connection.setAutoCommit();

URL

String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";
// mysql---3306
//協議：  jdbc：mysql://主機地址：端口號/數據庫名？參數1&參數2&參數3

//oralce -- 1521
//jdbc：oracle：thin：@localhost：1521：sid

Statement執行SQL的對象，PrepareStatement執行SQL的對象

String sql = “SELECT * FROM users”； // 編寫SQL 
statement.execute(); //執行任何SQL
statement.executeQuery(); //查詢操作返回ResultSet
statement.executeUpdate(); // 更新、插入、刪除，都是用這個，返回一個受影響的行數

ResultSet 查詢的結果集，封裝了所有的查詢結果

獲得指定的數據類型

resultSet.getobject(); // 在不知道列類型的情況下使用 
//如果知道列的類型就使用特定的類型
resultSet.getstring()
resultSet.getin()
    ...

遍歷，指針

resulSet.beforeFirst();  //移動到最前面
resulSet.afterLast(); // 移動到最后
resulSet.next(); // 移動到下一個數據
resulSet.previous(); // 移動到前一行
resulSet.absolute(row); //移動到指定行

釋放資源

//6.釋放連接
resultSet.close();
statement.close();
connection.close();   //耗資源，用完關掉！

statement對象

jdbc中的statement對象用於向數據庫發送SQL語句，想完成對數據庫的增刪改查，只需要通過這個對象向數據庫發送增刪改查語句即可。

Statement對象的executeUpdate方法，用於向數據庫發送增、刪、改的sql語句，executeUpdate執行完后，將會返回一個整數（即增刪改語句導致了數據庫幾行數據發生了變化)。

Statement.executeQuery方法用於向數據庫發送查詢語句，executeQuery方法返回代表查詢結果的ResultSet對象。

CRUD操作-create

使用executeUpdate（String sql）方法完成數據添加操作：

Statement st =conn.createStatement();
String sql = "insert into user(...) values(...)";
int num = st.executeUpdate(sql);
if(num>0){
    System.out.println("插入成功！");
}

同理 delete update也是一樣只是sql不一樣

CRUD操作-read

使用executeQuery方法來完成數據查詢的操作

statement st= conn.createStatement();
String sql="select * from user where id =1";
ResultSet rs =st.execute(sql);
while(rs.next()){
    //根據獲取列的數據類型，分別調用rs的相應方法映射到java對象中
}

代碼實現

提取工具類

package lijinyu.lesson02.utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils {
    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static {
        try {
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);

            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");

            // 1.驅動只用加載一次
            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // 獲取連接
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    //釋放連接資源
    public static void release(Connection connection, Statement st, ResultSet rs) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (st != null) {
            try {
                st.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }
}

編寫增刪改的方法 `executeUpdate`

package lijinyu.lesson02;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();  //獲取數據庫連接
            st = conn.createStatement(); //獲得sql的執行對象
            String sql = "insert into users(`id`,`name`,`password`) values(54,'ljy','8453')";

            int i = st.executeUpdate(sql);
            if (i > 0) {
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);

        }
    }
}

package lijinyu.lesson02;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestDelete {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();  //獲取數據庫連接
            st = conn.createStatement(); //獲得sql的執行對象
            String sql = "delete from `users` where id = 4";

            int i = st.executeUpdate(sql);
            if (i > 0) {
                System.out.println("刪除成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);

        }
    }
}

package lijinyu.lesson02;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestUpdate {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();  //獲取數據庫連接
            st = conn.createStatement(); //獲得sql的執行對象
            String sql = "update users set `name`='ljy',`email`='84533616@qq.com' where id=1";

            int i = st.executeUpdate(sql);
            if (i > 0) {
                System.out.println("修改成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);

        }
    }
}

查詢

package lijinyu.lesson02;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestSelect {
    public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        // 1. 獲取連接
        try {
            conn = JdbcUtils.getConnection();
            // 2. 獲取執行對象
            st = conn.createStatement();

            //SQL語句
            String sql = "select * from users where id =1";
            rs = st.executeQuery(sql); //查詢完畢。會返回一個結果集
            while (rs.next()) {
                System.out.println(rs.getString("NAME"));
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);
        }
    }
}

SQL注入的問題

sql存在漏洞，會被攻擊導致數據泄露 SQL會被拼接 or

package lijinyu.lesson02;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class SQL注入 {
    public static void main(String[] args) {
        // 正常登錄
        // login("ljy","123456");
        login(" ' or'1=1", "'or'1=1");

    }

    //登錄業務
    public static void login(String username, String password) {

        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        // 1. 獲取連接
        try {
            conn = JdbcUtils.getConnection();
            // 2. 獲取執行對象
            st = conn.createStatement();

            //select * from users where `name`='ljy` and `password` = '123456';
            //select * from users where `name`='' or '1=1' and `password`='or'1=1   ;
            String sql = "select * from users where `NAME`='" + username + "'AND `password`='" + password + "'";
            rs = st.executeQuery(sql); //查詢完畢。會返回一個結果集
            while (rs.next()) {
                System.out.println(rs.getString("NAME"));
                System.out.println(rs.getString("password"));
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);
        }
    }
}

PreparedStatement對象

PreparedStatement可以防止SQL注入，效率更高！

新增

package lijinyu.lesson03;

import lijinyu.lesson02.utils.JdbcUtils;

import java.util.Date;
import java.sql.*;

public class TestInsert {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用問號 ？ 占位符代替參數
            String sql = "insert into users(`id`,`name`,`password`,`birthday`) values(?,?,?,?)";
            st = conn.prepareStatement(sql); //預編譯SQL，先寫SQL,然后不執行

            //手動給參數賦值
            //set(x,x) 第一個x代表第幾個？ 第2個x代表具體的賦值
            st.setInt(1, 5); //id賦值
            st.setString(2, "lijiynu");
            st.setString(3, "123456789987");
            //注意點：sql.date  數據庫
            //  util.date  java  new Date().getTime() 獲得時間戳
            st.setDate(4, new java.sql.Date(new Date().getTime()));

            //執行
            int i = st.executeUpdate();
            if (i > 0) {
                System.out.println("插入成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, null);
        }
    }
}

刪除

package lijinyu.lesson03;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;

public class TestDelete {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用問號 ？ 占位符代替參數
            String sql = "delete  from users where id =?";
            st = conn.prepareStatement(sql); //預編譯SQL，先寫SQL,然后不執行
            //手動給參數賦值
            st.setInt(1, 5);

            //執行
            int i = st.executeUpdate();
            if (i > 0) {
                System.out.println("刪除成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, null);
        }
    }
}

更新

package lijinyu.lesson03;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestUpdate {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        try {
            conn = JdbcUtils.getConnection();

            //區別
            //使用問號 ？ 占位符代替參數
            String sql = "update users set `name` = ? where `id`=?  ;";
            st = conn.prepareStatement(sql); //預編譯SQL，先寫SQL,然后不執行
            //手動給參數賦值
            st.setString(1, "李四");
            st.setInt(2, 1);

            //執行
            int i = st.executeUpdate();
            if (i > 0) {
                System.out.println("更新成功");
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, null);
        }
    }
}

查詢

package lijinyu.lesson03;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestSelect {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;

        try {
            conn = JdbcUtils.getConnection();
            String sql = "select * from users where id =?";

            st = conn.prepareStatement(sql);  //預編譯

            st.setInt(1, 1);  //傳遞參數

            //執行
            rs = st.executeQuery();
            if (rs.next()) {
                System.out.println(rs.getString("name"));
            }


        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);
        }
    }
}

防止SQL注入

package lijinyu.lesson03;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.*;

public class SQL注入 {
    public static void main(String[] args) {
        // 正常登錄
        login("李四", "123456");
        // login(" '' or 1=1", "123456");

    }

    //登錄業務
    public static void login(String username, String password) {

        Connection conn = null;
        PreparedStatement st = null;
        ResultSet rs = null;
        // 1. 獲取連接
        try {
            conn = JdbcUtils.getConnection();
            //PreparedStatement放注入的本質：把傳遞進來的參數當作字符
            //假設其中存在轉義字符,就直接忽略，’會被直接轉義
            String sql = "SELECT * FROM `users` WHERE `NAME`= ? AND `PASSWORD`=?";

            st = conn.prepareStatement(sql);
            st.setString(1, username);
            st.setString(2, password);

            rs = st.executeQuery(sql); //查詢完畢。會返回一個結果集
            while (rs.next()) {
                System.out.println(rs.getString("NAME"));
                System.out.println(rs.getString("password"));
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JdbcUtils.release(conn, st, rs);
        }
    }
}

使用IDEA連接數據庫

連接mysql

選擇數據庫

查詢數據庫信息

更新信息

這里步驟二就是提交信息的意思

創建控制台寫SQL語句

表示切換數據庫

如果連接數據庫失敗

在這里修改改數據庫對應的版本SQL

JDBC操作事務

要么都成功，要么都失敗

ACID原則

原子性：要么全部完成，要么都不完成

一致性：結果總數不變

隔離性：多個進程互不干擾

持久性：一旦提交不可逆，持久化到數據庫了。

隔離性的問題：

臟讀：一個事務讀取了另一個沒有提交的事務

不可重復讀：在同一個事務內，重復讀取表中的數據，表數據發生了改變（不知道用原來的數據還是現在的數據）

虛度（幻讀）：在一個事務內，讀取到了別人插入的數據，導致了前后讀出來的結果不一致

代碼實現

開啟事務conn.setAutoCommit(false)
一組事務執行完畢，提交事務
可以在catch語句中顯示的定義回滾語句，但是默認失敗就會回滾

package lijinyu.lesson04;

import lijinyu.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
// JDBC中的事務
public class TestTransaction {
    public static void main(String[] args) {
        Connection conn =null;
        PreparedStatement st =null;
        ResultSet rs = null;

        try {
            conn = JdbcUtils.getConnection();
            //關閉數據庫的自動提交功能,自動會開啟事務
            conn.setAutoCommit(false); // 開啟事務

            String sql1="update account set money = money-100 where name='A'";
            st = conn.prepareStatement(sql1);
            st.executeUpdate();
            String sql2="update account set money = money+100 where name='B'";
            st = conn.prepareStatement(sql2);
            st.executeUpdate();

            //業務完畢，提交事務
            conn.commit();
            System.out.println("更新成功");

        } catch (SQLException throwables) {
            try {
                conn.rollback();  //如果失敗則回滾事務
            } catch (SQLException e) {
                e.printStackTrace();
            }
            throwables.printStackTrace();
        }finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

數據庫連接池

數據庫連接--執行完畢 --釋放

連接--釋放十分浪費系統資源

池化技術：准備一些預先的資源，過來就連接預先准備好的

--- 開門--業務員：等待 -- 服務 --‘

15個業務員

最小連接數：10

最大連接數：15 業務最高承載上限

等待超時：100ms

編寫連接池，實現一個接口： DataSource

開源數據源實現(拿來即用)

DBCP

C3P0

Druid：阿里巴巴

使用了這些數據庫連接池之后，我們在項目開發中就不需要編寫連接數據庫的代碼了！

DBCP

需要用到的jar包：

commons-dbcp-1.4、commons-pool-1.6

C3P0

c3p0-0.9.5.5 、mchange-commons-java-0.2.19

結論

無論使用什么數據源，本質還是一樣，DataSource接口不會變，方法就不會變

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 eclipse怎么連接到MySQL中的表！！！！！在phpmyadmin的docker容器連接到mysql的docker容器中 Navicat無法連接到MySQL 解決IDEA和DataGrip無法連接到MySQL服務器的問題（如果下載的mysql為8.0版本以上的話）解決Navicat無法連接到MySQL的問題 docker 從 tomcat 容器連接到 mysql 容器解決Navicat無法連接到MySQL的問題 Visual Studio 2015 Community連接到Mysql 1關於如何用Navicat連接到xampp安裝的mysql navicat 無法連接到騰訊雲Mysql

在IDEA中連接到MySQL

JDBC（重點）

數據庫驅動

JDBC

第一個JDBC程序

statement對象

代碼實現

提取工具類

編寫增刪改的方法 executeUpdate

查詢

PreparedStatement對象

使用IDEA連接數據庫

連接mysql

選擇數據庫

查詢數據庫信息

更新信息

創建控制台 寫SQL語句

JDBC操作事務

數據庫連接池

開源數據源實現(拿來即用)

免責聲明！

編寫增刪改的方法 `executeUpdate`

創建控制台寫SQL語句