使用java连接mysql数据库进行数据的查询插入更新及删除

准备

1.需要mysql-connector-java包，我这里使用的是maven，给出我的pom配置

<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.8-dmr</version>
</dependency>

2.在mysql中已创建好数据库，假设我的数据库为hdfs，并且我已经建好一张表为syn_table

连接数据库并进行操作

连接数据库

java.sql包中主要包含四个类，分别是：

1. DriverManager类:管理驱动程序和连接数据库

2. Connection接口：管理建立好的数据库连接

3. Statement接口：执行sql语句

4. ResultSet接口:存储数据库返回的记录

连接的代码如下

Class.forname("com.mysql.jdbc.Driver"); //指定驱动名称
Connection connection=DriverManager.getConnection(url,user,password); //创建connection对象

实际例子如下：
Connection con = null;
String url = "jdbc:mysql://localhost:3306/hdfs"；//本机默认端口为3306
String user="root";
String password="root";
Connection connection=DriverManager.getConnection(url,user,password); //创建Connection对象

操作数据库

也就是增删改查，以下代码分别代表了几类操作，使用Statement对象执行语句，result获取结果，对于多行数据，使用result.next()进行迭代

//查询使用Statement对象的excuteQuery()方法
Statement s = con.createStatement();
ResultSet result = s.executeQuery("select * from syn_table where syned = 0;");
while(result.next()){
String t1 = result.getString("id");
String t2 = result.getString("address");
String t3 = result.getString("syned");
System.out.println(t1+" "+t2+" "+t3);
}

//插入以及更新删除需要使用Statement对象的excuteUpdate()方法，其中的sql语句必须是插入更新或者删除语句
int t = s.executeUpdate("UPDATE syn_table SET address = 'hdfs://192.168.50:70:8020/user/input/5.txt' WHERE  id ='2014419' ");
System.out.println(t);

//也可以使用通用的方法excute()方法，该方法返回boolean类型数据，true表示执行了查询语句，false表示执行了更新等操作

//查询完成后需要对对象进行关闭，最后创建的需要先进行关闭，代码如下
if(result!=null){ //判断ResultSet对象是否为空
result.close();//调用close()方法关闭ResultSet对象
}
if(statement!=null){
statement.close();
}
if(connection!=null){
connection.close();
}