java mysql 连接

java 通过使用 jdbc 来连接 mysql 数据库。java 连接 mysql 需要专用的驱动包，官方下载地址为：http://dev.mysql.com/downloads/connector/j/，解压后得到 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");

1. 创建测试数据

接下来我们在 mysql 中创建 yapf 数据库，并创建 websites 数据表，表结构如下：

create table `websites` (
    `id` int(11) not null auto_increment,
    `name` char(20) not null default '' comment '站点名称',
    `url` varchar(255) not null default '',
    `alexa` int(11) not null default '0' comment 'alexa 排名',
    `country` char(10) not null default '' comment '国家',
    primary key (`id`)
    ) engine=innodb auto_increment=10 default charset=utf8;

插入一些数据：

insert into `websites` values ('1', 'google', 'https://www.google.cm/', '1', 'usa');
insert into `websites` values ('2', '淘宝', 'https://www.taobao.com/', '13', 'cn'),;
insert into `websites` values ('3', '硕编程', 'http://www.yapf.com/', '888', '');
insert into `websites` values ('4', '微博', 'http://weibo.com/', '20', 'cn');
insert into `websites` values ('5', 'facebook', 'https://www.facebook.com/', '3', 'usa');

数据表显示如下：

2. 连接数据库

以下范例使用了 jdbc 连接 mysql 数据库，注意一些数据如用户名，密码需要根据你的开发环境来配置：

package com.yapf.test;

import java.sql.*;
    
public class mysqldemo {
    
    // mysql 8.0 以下版本 - jdbc 驱动名及数据库 url
    static final string jdbc_driver = "com.mysql.jdbc.driver";  
    static final string db_url = "jdbc:mysql://localhost:3306/yapf";
    
    // mysql 8.0 以上版本 - jdbc 驱动名及数据库 url
    //static final string jdbc_driver = "com.mysql.cj.jdbc.driver";  
    //static final string db_url = "jdbc:mysql://localhost:3306/yapf?usessl=false&allowpublickeyretrieval=true&servertimezone=utc";
    
    
    // 数据库的用户名与密码，需要根据自己的设置
    static final string user = "root";
    static final string pass = "123456";
    
    public static void main(string[] args) {
        connection conn = null;
        statement stmt = null;
        try{
            // 注册 jdbc 驱动
            class.forname(jdbc_driver);
        
            // 打开链接
            system.out.println("连接数据库...");
            conn = drivermanager.getconnection(db_url,user,pass);
        
            // 执行查询
            system.out.println(" 范例化statement对象...");
            stmt = conn.createstatement();
            string sql;
            sql = "select id, name, url from websites";
            resultset rs = stmt.executequery(sql);
        
            // 展开结果集数据库
            while(rs.next()){
                // 通过字段检索
                int id  = rs.getint("id");
                string name = rs.getstring("name");
                string url = 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(sqlexception se){
            // 处理 jdbc 错误
            se.printstacktrace();
        }catch(exception e){
            // 处理 class.forname 错误
            e.printstacktrace();
        }finally{
            // 关闭资源
            try{
                if(stmt!=null) stmt.close();
            }catch(sqlexception se2){
            }// 什么都不做
            try{
                if(conn!=null) conn.close();
            }catch(sqlexception se){
                se.printstacktrace();
            }
        }
        system.out.println("goodbye!");
    }
}