用Java连接Mysql

使用Java连接MySQL，实现对数据库表格的增删改查。

导入mysql-connector-java-5.1.38-bin.jar

使用maven 自动导入jar包

正常创建一个Java Project，转换成maven

然后在项目中找到pom.xml文件并打开



进入然后进去Maven官网

https://mvnrepository.com/ 这里有庞大的jar包资源



然后选择版本然后进入（建议不要点击最新版本的，中等偏新版本的或许比较稳定。）



接着，复制红色框里面的代码。



将复制的代码粘贴到pom.xml文件中



保存pom.xml文件，刷新项目

实现代码：

主要分以下几个步骤:

a. 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver").newInstance();
b. 使用DriverManager获取Connection对象
conn = DriverManager.getConnection(url，user，password);
c. 使用Connection对象生成Statement对象
stmt = conn.createStatement();
d. 使用Statement对象调用执行SQL语句方法生成结果集ResultSet
rs = stmt.executeQuery(sqlstr);
e. 使用结果集ResultSet
f. 释放数据库连接资源

注意：

Statement 接口提供了三种执行 SQL 语句的方法：executeQuery、executeUpdate 和 execute。使用哪一个方法由 SQL 语句所产生的内容决定。

1. ResultSet executeQuery(String sql); 

  执行SQL查询，并返回ResultSet 对象。用于产生单个结果集的语句 

2.int executeUpdate(String sql);

  可执行增，删，改，返回执行受到影响的行数。

 3. boolean execute(String sql);

  可执行任何SQL语句，返回一个布尔值，表示是否返回ResultSet 。

ResultSet使用：

例如：ResultSet rs;声明一个ResultSet类型的rs变量，用来保存数据库里提取出来的记录，最后通过一个循环把所有的记录显示出来

查询mybd数据库 的customertb表

public static void test1() {
try {
//加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
//使用DriverManager获取Connection对象
Connection	conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb","root","123456");
//使用Connection对象生成Statement对象
Statement statement = conn.createStatement();
//使用结果集ResultSe
ResultSet rs = statement.executeQuery("select * from customertb");
while (rs.next()) {
System.out.println(rs.getString("id"));
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}

因为我输入了id，所以输出结果只有id。



删除表格中，id=2的一行内容

public static void test2() {
try {
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 使用DriverManager获取Connection对象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "root", "123456");
// 使用Connection对象生成Statement对象
Statement statement = conn.createStatement();
// 2.执行SQL删除语句
statement.execute("delete from customertb where id = '2' ");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}

执行结果：



接着修改id=3，属性为name里面的内容

public static void test3() {
try {
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 使用DriverManager获取Connection对象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "root", "123456");
// 使用Connection对象生成Statement对象
Statement statement = conn.createStatement();
// 3执行SQL修改语句
statement.executeUpdate("update customertb set name='jige' where id='3'");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}

修改后的结果：