1、执行查询操作
package com.yinggu.demo1;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
import org.junit.Test;
* 此类用于演示访问数据库,执行增删改查操作
*
* @author:黑猴子的家
* @博客 :https://www.jianshu.com/u/37fd8e2dff4c
public class TestConnection3 {
/*
* 执行查询
*/
@Test
public void testQuery() throws Exception {
Properties pro = new Properties();
pro.load(new FileInputStream("src/db.properties"));
String driverClass = pro.getProperty("driverClass");
String url = pro.getProperty("url");
String user = pro.getProperty("user");
String password = pro.getProperty("password");
// 1.加载驱动
Class.forName(driverClass);
// 2.获取连接
Connection connection = DriverManager.getConnection(url, user, password);
// 3.访问数据库,执行查询
// 3-1.获取命令对象
Statement statement = connection.createStatement();
// 3-2.执行查询
ResultSet set = statement.executeQuery("select * from beauty");
// set.afterLast();
while (set.next()) {
// 方式一:根据列索引获取该列的值
int id = set.getInt(1);// 获取该1列的值
String name = set.getString(2);// 获取该2列的值
// 方式二:根据列名获取该列的值
int id2 = set.getInt("id");
String name2 = set.getString("Name");
// 方式三:根据列名获取该列的值,返回Object类型
Object id3 = set.getObject("id");
Object name3 = set.getObject("Name");
System.out.println(id + "\t" + name);
System.out.println(id2 + "\t" + name2);
System.out.println(id3 + "\t" + name3);
}
// 4.关闭连接
set.close();
statement.close();
connection.close();
}
}
2、执行增删改操作
/*
* 执行增删改
*/
@Test
public void testUpdate() throws Exception {
Properties pro = new Properties();
pro.load(new FileInputStream("src/db.properties"));
String driverClass = pro.getProperty("driverClass");
String url = pro.getProperty("url");
String user = pro.getProperty("user");
String password = pro.getProperty("password");
// 1.加载驱动
Class.forName(driverClass);
// 2.获取连接
Connection connection = DriverManager.getConnection(url, user, password);
// 3.访问数据库,执行增删改的操作 ★
// 3-1. 获取命令对象
Statement statement = connection.createStatement();
// 3-2.执行sql命令并返回
// statement.execute(sql);//执行任何sql语句,返回是否结果为结果集
// statement.executeQuery(sql);//执行查询语句,返回结果集对象
// statement.executeUpdate 执行增删改语句,返回受影响的行数
int update = statement.executeUpdate(
"update beauty set sex='男' where name='小明明'");
// 3-3.处理结果
System.out.println(update > 0 ? "执行成功":"执行失败");
// 4.关闭连接
statement.close();
connection.close();
}
}
上数据库查看一下,验证是否已经改了
3、关闭资源
//关闭连接
set.close();
statement.close();
connection.close();
连接正序开,倒叙关闭,如果不关闭,正式项目,比如电商项目,会造成资源浪费,降低性能,以至于出现异常
网友评论