如果看过笔者之前《SQL基础教程》阅读笔记系列就会知道,笔者使用的是Mysql
首先笔者到了 maven repository 官网: https://mvnrepository.com
找到了connector/J 地址:https://mvnrepository.com/artifact/mysql/mysql-connector-java
选择了最高版本:8.0.13
由于笔者用的是maven项目,得到xml:
<!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.13</version>
</dependency>
加入到eclipse中maven项目的pom.xml的<dependencies></dependencies> 中间
但是可能是因为国外的网站不够稳定,更新项目之后,仍然不可用
为了解决国外网站不稳定的问题,有一个方法就是,利用阿里镜像:
首先:Eclipse->preferences->Maven ->User Settings
这个时候 User Settings 应该是空的
自己创建一个文件路径应该和repository是一个文件下的,名字为 settings.xml
其中放置的内容:
<?xml version="1.0" encoding="UTF-8"?>
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">
<pluginGroups>
</pluginGroups>
<proxies>
</proxies>
<servers>
</servers>
<mirrors>
<mirror>
<id>nexus</id>
<name>Tedu Maven</name>
<mirrorOf>*</mirrorOf>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
<!-- <url>http://maven.aliyun.com/content/groups/public</url> -->
</mirror>
</mirrors>
<profiles>
</profiles>
<activeProfiles>
</activeProfiles>
</settings>
然后apply,这个时候,就修改成阿里镜像的了
这个时候再在 pom.xml 中加入connector/J的xml:
保存,更新
这个时候查看 Maven dependencies 就会发现,mysql-connector-java-8.0.13.jar 在里面
接着就是写程序连接数据库的过程:
package cn.athena.java_base_demo;
import java.sql.*;
public class MysqlDemo{
// jdbc 代表使用JDBC 驱动,mysql代表连接的是mysql数据库,localhost:3306 代表使用的是本地3306端口 shop是我使用的数据库
static final String DB_URL = "jdbc:mysql://localhost:3306/shop";
// 用户名 和 密码,一般来说用户名是root
static final String USER = "****";
static final String PASS = "*******";
public static void main(String[] args) {
// 声明两个对象,Connection 对象可以得到描述表的信息,Statement 对象可以执行SQL语句,而且一次只有一个Statement对象
Connection conn = null;
Statement stmt = null;
try {
// Class.forName("com.mysql.jdbc.Driver"); 将对应的对象打开,但是这里已经自动进行了,因此,这一步没有什么必要了
System.out.println();
System.out.println("opening the database...");
// 使用用户名和密码打开数据库,返回 Connection 对象
conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println("get instance...");
// 获得Statement 对象
stmt = conn.createStatement();
String sql;
sql = "SELECT product_id, product_name, product_type FROM Product";
// 执行Mysql语句,从 Product表中获得 product_id product_name 和 product_type 列的信息
// rs 获得的是结果
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()) {
// getInt getString 都是指获得参数所指的那一列的数据
int id = rs.getInt("product_id");
String name = rs.getString("product_name");
String type = rs.getString("product_type");
System.out.print("product_id:"+id+" ");
System.out.print("product_name:"+name+" ");
System.out.print("product_type:"+type);
System.out.println();
}
// 使用后关闭
rs.close();
stmt.close();
conn.close();
}catch(SQLException se) {//异常处理
se.printStackTrace();
}catch(Exception e) {
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");
}
}
结果:
opening the database...
get instance...
product_id:1 product_name:T恤衫 product_type:衣服
product_id:2 product_name:打孔机 product_type:办公用品
product_id:3 product_name:运动T恤 product_type:衣服
product_id:4 product_name:菜刀 product_type:厨房用具
product_id:5 product_name:高压锅 product_type:厨房用具
product_id:6 product_name:叉子 product_type:厨房用具
product_id:7 product_name:擦菜板 product_type:厨房用具
product_id:8 product_name:圆珠笔 product_type:办公用品
Goodbye
这样,成功完成Java和 Mysql的连接