菜鸟教程 -- 学的不仅是技术,更是梦想!

Java 教程
(追記) (追記ここまで)

Java MySQL 连接

本章节我们为大家介绍 Java 如何使用 使用 JDBC 连接 MySQL 数据库。

Java 连接 MySQL 需要驱动包,最新版下载地址为:http://dev.mysql.com/downloads/connector/j/ ,解压后得到 jar 库文件,然后在对应的项目中导入该库文件。

你可以下载本站提供的 jar 包:mysql-connector-java-5.1.39-bin.jar

本实例使用的是 Eclipse,导入 jar 包:

MySQL 8.0 以上版本的数据库连接有所不同:

  • 1、MySQL 8.0 以上版本驱动包版本 mysql-connector-java-8.0.16.jar

  • 2、com.mysql.jdbc.Driver 更换为 com.mysql.cj.jdbc.Driver

  • MySQL 8.0 以上版本不需要建立 SSL 连接的,需要显示关闭。

  • allowPublicKeyRetrieval=true 允许客户端从服务器获取公钥。

  • 最后还需要设置 CST。

加载驱动与连接数据库方式如下:

Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test_demo?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC","root","password");

创建测试数据

接下来我们在 MySQL 中创建 RUNOOB 数据库,并创建 websites 数据表,表结构如下:

CREATETABLE`websites`(`id`int(11)NOTNULLAUTO_INCREMENT, `name`char(20)NOTNULLDEFAULT''COMMENT'站点名称', `url`varchar(255)NOTNULLDEFAULT'', `alexa`int(11)NOTNULLDEFAULT'0'COMMENT'Alexa 排名', `country`char(10)NOTNULLDEFAULT''COMMENT'国家', PRIMARYKEY(`id`))ENGINE=InnoDBAUTO_INCREMENT=10DEFAULTCHARSET=utf8;

插入一些数据:

INSERTINTO`websites`VALUES('1', 'Google', 'https://www.google.cm/', '1', 'USA'), ('2', '淘宝', 'https://www.taobao.com/', '13', 'CN'), ('3', '菜鸟教程', 'http://www.runoob.com', '5892', ''), ('4', '微博', 'http://weibo.com/', '20', 'CN'), ('5', 'Facebook', 'https://www.facebook.com/', '3', 'USA');

数据表显示如下:


连接数据库

以下实例使用了 JDBC 连接 MySQL 数据库,注意一些数据如用户名,密码需要根据你的开发环境来配置:

MySQLDemo.java 文件代码:

packagecom.runoob.test; importjava.sql.*; publicclassMySQLDemo{// MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URLstaticfinalStringJDBC_DRIVER = "com.mysql.jdbc.Driver"; staticfinalStringDB_URL = "jdbc:mysql://localhost:3306/RUNOOB"; // MySQL 8.0 以上版本 - JDBC 驱动名及数据库 URL//static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver"; //static final String DB_URL = "jdbc:mysql://localhost:3306/RUNOOB?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";// 数据库的用户名与密码,需要根据自己的设置staticfinalStringUSER = "root"; staticfinalStringPASS = "123456"; publicstaticvoidmain(String[]args){Connectionconn = null; Statementstmt = null; try{// 注册 JDBC 驱动Class.forName(JDBC_DRIVER); // 打开链接System.out.println("连接数据库..."); conn = DriverManager.getConnection(DB_URL,USER,PASS); // 执行查询System.out.println(" 实例化Statement对象..."); stmt = conn.createStatement(); Stringsql; sql = "SELECT id, name, url FROM websites"; ResultSetrs = stmt.executeQuery(sql); // 展开结果集数据库while(rs.next()){// 通过字段检索intid = rs.getInt("id"); Stringname = rs.getString("name"); Stringurl = rs.getString("url"); // 输出数据System.out.print("ID: " + id); System.out.print(", 站点名称: " + name); System.out.print(", 站点 URL: " + url); System.out.print("\n"); }// 完成后关闭rs.close(); stmt.close(); conn.close(); }catch(SQLExceptionse){// 处理 JDBC 错误se.printStackTrace(); }catch(Exceptione){// 处理 Class.forName 错误e.printStackTrace(); }finally{// 关闭资源try{if(stmt!=null)stmt.close(); }catch(SQLExceptionse2){}// 什么都不做try{if(conn!=null)conn.close(); }catch(SQLExceptionse){se.printStackTrace(); }}System.out.println("Goodbye!"); }}

以上实例执行输出结果如下:

AI 思考中...

5 篇笔记 写笔记

  1. #0

    哈哈哈哈哈。。。呃~

    248***[email protected]

    参考地址

    91

    DAO 模式

    DAO (DataAccessobjects 数据存取对象)是指位于业务逻辑和持久化数据之间实现对持久化数据的访问。通俗来讲,就是将数据库操作都封装起来。

    对外提供相应的接口

    在面向对象设计过程中,有一些"套路"用于解决特定问题称为模式。

    DAO 模式提供了访问关系型数据库系统所需操作的接口,将数据访问和业务逻辑分离对上层提供面向对象的数据访问接口。

    从以上 DAO 模式使用可以看出,DAO 模式的优势就在于它实现了两次隔离。

    • 1、隔离了数据访问代码和业务逻辑代码。业务逻辑代码直接调用DAO方法即可,完全感觉不到数据库表的存在。分工明确,数据访问层代码变化不影响业务逻辑代码,这符合单一职能原则,降低了藕合性,提高了可复用性。
    • 2、隔离了不同数据库实现。采用面向接口编程,如果底层数据库变化,如由 MySQL 变成 Oracle 只要增加 DAO 接口的新实现类即可,原有 MySQ 实现不用修改。这符合 "开-闭" 原则。该原则降低了代码的藕合性,提高了代码扩展性和系统的可移植性。

    一个典型的DAO 模式主要由以下几部分组成。

    • 1、DAO接口: 把对数据库的所有操作定义成抽象方法,可以提供多种实现。
    • 2、DAO 实现类: 针对不同数据库给出DAO接口定义方法的具体实现。
    • 3、实体类:用于存放与传输对象数据。
    • 4、数据库连接和关闭工具类: 避免了数据库连接和关闭代码的重复使用,方便修改。

    DAO 接口:

    public interface PetDao {
     /**
     * 查询所有宠物
     */
     List<Pet> findAllPets() throws Exception;
    }

    DAO 实现类:

    public class PetDaoImpl extends BaseDao implements PetDao {
     /**
     * 查询所有宠物
     */
     public List<Pet> findAllPets() throws Exception {
     Connection conn=BaseDao.getConnection();
     String sql="select * from pet";
     PreparedStatement stmt= conn.prepareStatement(sql);
     ResultSet rs= stmt.executeQuery();
     List<Pet> petList=new ArrayList<Pet>();
     while(rs.next()) {
     Pet pet=new Pet(
     rs.getInt("id"),
     rs.getInt("owner_id"),
     rs.getInt("store_id"),
     rs.getString("name"),
     rs.getString("type_name"),
     rs.getInt("health"),
     rs.getInt("love"),
     rs.getDate("birthday")
     );
     petList.add(pet);
     }
     BaseDao.closeAll(conn, stmt, rs);
     return petList;
     }
    }

    宠物实体类(里面get/set方法就不列出了)

    public class Pet {
     private Integer id; 
     private Integer ownerId; //主人ID
     private Integer storeId; //商店ID
     private String name; //姓名
     private String typeName; //类型
     private int health; //健康值
     private int love; //爱心值
     private Date birthday; //生日
    }

    连接数据库

    public class BaseDao {
     private static String driver="com.mysql.jdbc.Driver";
     private static String url="jdbc:mysql://127.0.0.1:3306/epet";
     private static String user="root";
     private static String password="root";
     static {
     try {
     Class.forName(driver);
     } catch (ClassNotFoundException e) {
     e.printStackTrace();
     }
     }
     
     public static Connection getConnection() throws SQLException {
     return DriverManager.getConnection(url, user, password); 
     }
     
     public static void closeAll(Connection conn,Statement stmt,ResultSet rs) throws SQLException {
     if(rs!=null) {
     rs.close();
     }
     if(stmt!=null) {
     stmt.close();
     }
     if(conn!=null) {
     conn.close();
     }
     }
     
     public int executeSQL(String preparedSql, Object[] param) throws ClassNotFoundException {
     Connection conn = null;
     PreparedStatement pstmt = null;
     /* 处理SQL,执行SQL */
     try {
     conn = getConnection(); // 得到数据库连接
     pstmt = conn.prepareStatement(preparedSql); // 得到PreparedStatement对象
     if (param != null) {
     for (int i = 0; i < param.length; i++) {
     pstmt.setObject(i + 1, param[i]); // 为预编译sql设置参数
     }
     }
     ResultSet num = pstmt.executeQuery(); // 执行SQL语句
     } catch (SQLException e) {
     e.printStackTrace(); // 处理SQLException异常
     } finally {
     try {
     BaseDao.closeAll(conn, pstmt, null);
     } catch (SQLException e) { 
     e.printStackTrace();
     }
     }
     return 0;
     }
     
    }
    哈哈哈哈哈。。。呃~

    哈哈哈哈哈。。。呃~

    248***[email protected]

    参考地址

    8年前 (2018年05月07日)
  2. #0

    TiAmo

    576***[email protected]

    29

    MySQL 8.0 以上版本:

    驱动包版本 mysql-connector-java-8.0.12.jar

    数据库 URL 需要声明是否使用 SSL 安全验证及指定服务器上的时区:

    static final String DB_URL = jdbc:mysql://localhost:3306/runoob?useSSL=false&serverTimezone=UTC;
    conn = DriverManager.getConnection(DB_URL,USER,PASS);

    原本的驱动器是:

    Class.forName("com.mysql.jdbc.Driver");

    在 IDEA 里面提示是: Loading class `com.mysql.jdbc.Driver'. This is deprecated. The new driver class is `com.mysql.cj.jdbc.Driver'. The driver is automatically registered via the SPI and manual loading of the driver class is generally unnecessary

    意思是说原本的驱动器不赞成 或者 是废弃了,自动换成了新的驱动器 com.mysql.cj.jdbc.Driver

    Class.forName("com.mysql.cj.jdbc.Driver");
    TiAmo

    TiAmo

    576***[email protected]

    8年前 (2018年08月23日)
  3. #0

    在 JDBC4.0 之前,连接数据库的时候,通常会用 Class.forName("com.mysql.jdbc.Driver") 这句先加载数据库相关的驱动,然后再进行获取连接等的操作。而 JDBC4.0 之后不需要 Class.forName 来加载驱动,直接获取连接即可,这里使用了 Java 的SPI扩展机制来实现。

    7年前 (2019年05月05日)
  4. #0

    运行程序时抛出异常:

    Caused by: java.sql.SQLException: The server time zone value '�й���׼ɦ��' is unrecognized or represents more than one time zone. You must configure either the server or JDBC driver (via the serverTimezone configuration property) to use a more specifc time zone value if you want to utilize time zone support.

    解决办法:

    jdbcUrl=jdbc:mysql://localhost:3306/spring

    后面加上:

    jdbcUrl=jdbc:mysql://localhost:3306/spring?serverTimezone=UTC 

    但如果你的 jdbcUrl 类似下面:

    jdbcUrl=jdbc:mysql://localhost:3306/spring?serverTimezone=UTC&characterEncoding=utf-8

    就是有多个 params 的时候需要以 & 分开,但 & 要改为 &amp; 如下:

    jdbcUrl=jdbc:mysql://localhost:3306/spring?serverTimezone=UTC&characterEncoding=utf-8
    7年前 (2019年05月12日)
  5. #0

    baicai

    420***[email protected]

    29

    使用 Maven 自动下载 mysql-connector-java。

    在 maven 工程下的 pom.xml 中加mysql-connector-java 的依赖,只需要填想要的版本号,就能自动下载对应的 jar 包,更加方便。

    <dependency>
     <groupId>mysql</groupId>
     <artifactId>mysql-connector-java</artifactId>
     <version>8.0.16</version>
    </dependency>

    baicai

    420***[email protected]

    7年前 (2019年06月10日)

点我分享笔记

  • 昵称 (必填)
  • 邮箱 (必填)
  • 引用地址

AltStyle によって変換されたページ (->オリジナル) /