JDBC基础语句使用
作者：互联网
1 /* 2 * 插入数据
*第一步：创建JDBC四大参数
*第二步：加载驱动
*第三步：定义要传入的sql语句
*第四步：创建连接通道
*第五步：执行给定的SQL语句
3 */ 4 @Test 5 public void test2() throws ClassNotFoundException, SQLException { 6 // JDBC四大参数 7 String driverClassName = "com.mysql.jdbc.Driver"; 8 // 创建连接 9 String url = "jdbc:mysql://localhost:3306/db2"; 10 String user = "root"; 11 String password = "123"; 12 // 加载驱动 相当于 com.mysql.jdbc.Driver driverClassName = new com.mysql.jdbc.Driver(); 13 Class.forName(driverClassName);// 加载Driver这个类,该类实现了java.sql.Driver的驱动 14 //创建连接 连接Java程序和数据之间一个通道 15 Connection connection = DriverManager.getConnection(url, user, password); 16 //要传入的SQL语句 17 String sql = "INSERT INTO stu values (57,'张三',18,'男','四川',1200)"; 18 // 创建一个 Statement 对象来将 SQL 语句发送到数据库。 19 Statement statement = connection.createStatement(); 20 // 执行给定 SQL 语句,该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句（如 SQL DDL 语句）。 21 //返回受影响的语句的行数 22 statement.executeUpdate(sql); 23 24 }
1 public void test3() {
2 // 登录验证
3 Scanner sc = new Scanner(System.in);
4 Connection connection = null;
5 ResultSet row = null;
6 Statement statement = null;
7 try {
8 // 创建联接
9 connection = JdbcUtil.getConnection();
10
11 System.out.println("请输入姓名");
12 String sname = sc.nextLine();
13 System.out.println("请输入年龄");
14 int sage = sc.nextInt();
15 // 整理sql语句
16 String sql = "select * from stu where sname ='" + sname + "' and " + "sage = '" + sage + "' ";
17 // 传递数据
18 statement = connection.createStatement();
19 row = statement.executeQuery(sql);
20 if (row.next()) {
21 System.out.println("登录成功");
22 } else {
23 System.out.println("登录失败");
24 }
25 } catch (SQLException e) {
26 e.printStackTrace();
27 } finally {
28 sc.close();
29
30 try {
31 if (row.next()) {
32 row.close();
33 }
34
35 } catch (SQLException e) {
36 e.printStackTrace();
37 }
38 }
39
40 }
由于每次连接很麻烦，所以可以封装一个方法，作为JDBC工具包，返回值是Connection对象，使用配置文件来传递我们想要的四大参数
1 import java.io.FileInputStream;
2 import java.io.FileNotFoundException;
3 import java.io.IOException;
4 import java.sql.Connection;
5 import java.sql.DriverManager;
6 import java.sql.SQLException;
7 import java.util.Properties;
8 /*
9 *jdbc工具包
10 /
11 public class myUtil {
12 static Properties property = new Properties();
13 // Class.forName(driverClassName)
14 static {
15 try {
16 property.load(new FileInputStream("db2.properties"));
17 Class.forName(property.getProperty("driverClassName"));
18 }
19 catch (ClassNotFoundException e) {
20 e.printStackTrace();
21 } catch (FileNotFoundException e) {
22 e.printStackTrace();
23 } catch (IOException e) {
24 e.printStackTrace();
25 }
26 }
27 public static Connection getConnection() throws SQLException {
28 String url =property.getProperty("url");
29 String user =property.getProperty("user");
30 String password =property.getProperty("password");
31
32 return DriverManager.getConnection(url, user, password);
33
34 }
35 }
36 /*
37 *测试方法
38 */
39 @Test
40 public void test4() throws SQLException {// 修改数据
41 // 获取联接
42 Connection connection = myUtil.getConnection();
43 String sql = "update stu set sname = ? ,sage = ? where sid = 1";
44 // 传递数据
45 PreparedStatement prep = connection.prepareStatement(sql);
46 prep.setString(1, "张思");
47 prep.setInt(2, 15);
48 int executeUpdate = prep.executeUpdate();
49 System.out.println(executeUpdate);
50
51 }
1.使用别人封装好的jar包，好像还有连接池
2.使用PreparedStatement代替Statement，它的优点:使用？作为占位符，语句预编译，执行效率高;可以避免注入攻击（就是第二个登录方法里面输入das' or 1=1 -- dad das 也会登录成功 ）
1 import java.sql.Connection;
2 import java.sql.SQLException;
3
4 import com.mchange.v2.c3p0.ComboPooledDataSource;
5
6 public class JdbcUtil {
7 private static ComboPooledDataSource datasource = new ComboPooledDataSource();
8
9 //获取连接
10 public static Connection getConnection() throws SQLException {
11 return datasource.getConnection();
12 }
13 }
14
15
16 @Test
17 public void test5() throws SQLException {// 添加数据
18 Scanner sc = new Scanner(System.in);
19 // 获取连接
20 Connection connection = JdbcUtil.getConnection();
21 // 传递数据
22 String sql = "insert into stu(sid,sname,sage) values (?,?,?)";
23 PreparedStatement prepareStatement = connection.prepareStatement(sql);
24 System.out.println("输入要添加的ID");
25 int sid = sc.nextInt();
26 System.out.println("输入要添加的名字");
27 String sname = sc.next();
28 System.out.println("输入要添加的年龄");
29 int sage = sc.nextInt();
30 prepareStatement.setInt(1, sid);
31 prepareStatement.setString(2, sname);
32 prepareStatement.setInt(3, sage);
33 // 请求输入数据
34 int executeUpdate = prepareStatement.executeUpdate();
35 System.out.println(executeUpdate);
36
37 }
在Eclipse中使用事务处理，实现账户转账中的问题
1 /*
2 * ui层
3 */
4 public static void main(String[] args) {
5 Test01 t = new Test01();
6 try {
7 t.backService("张三", "李四", 100);
8 } catch (Exception e) {
9 System.out.println("转账失败");
10 }
11 }
12
13 /*
14 * service层的转账方法
15 */
16 public void backService(String from, String to, int money) throws Exception {// 事务操作,保证转账正常
17 // 创建同一个连接
18 Connection con = null;
19 try {
20 // 通过工具包创建与数据库的连接
21 con = JdbcUtil.getConnection();
22 // 开启手动事务
23 con.setAutoCommit(false);
24 // 调用dao层更新要存储的数据 ,from账户中的钱减少,to账户中的钱增多
25 updateAccount(con, from, -money);
26 //人为制造一个异常,假设from 转账成功 ,但是to没有收到钱,看数据库的数据回滚没有
27 // if(true) throw new Exception(); //当开启异常是转账失败,数据回滚 ,当关闭时成功转账
28 updateAccount(con, to, money);
29 //如果正常执行,则提交事务,此时数据库的值会改变 commit 承诺
30 con.commit();
31 } catch (SQLException e) {
32 //出现异常的处理方式是回滚事务(意思就是更改的信息不保存到数据库,还原到调用之前)
33 try {
34 con.rollback();
35 } catch (SQLException e1) {
36 System.out.println("回滚失败");
37 }
38 }
39 }
40
41 /*
42 * dao层执行数据的存储的方法
43 */
44 public void updateAccount(Connection con, String bname, int bbalan) throws SQLException {
45 // 已经创建连接,可以传递数据,使用mysql 语句
46 String sql = "update back set bbalan = bbalan + ? where bname = ? ";
47 PreparedStatement prepareStatement = con.prepareStatement(sql);
48 prepareStatement.setInt(1, bbalan);
49 prepareStatement.setString(2, bname);
50 // 请求修改
51 prepareStatement.executeUpdate();
52
53 }
54
55 }
JDBC:API
通过Java代码操作数据库
设计思想:
接口思想
制定接口:SUN官方---JDK
实现接口:数据库厂商自己实现---添加JDBC实现类jar包
使用接口:程序员
反射:
程序在运行时可以获取类的字节码对象，动态操作对象：创建对象，给属性赋值，调用方法
JDBC的使用
导入MySQL数据库驱动jar包:MySQL官方提供的操作MySQL数据库必须要的驱动包
四大参数
核心API
DriverManager:
getConnection()
Connection
createStatement()
Statement
String sql=" ('"+name+"', "
executeUpdate(sql)
executeQuery(sql)
ResultSet
DriverManager:
getConnection()
String sql=" ?,?";
Connection
preparedStatement(sql)
pstmt.setInt()
pstmt.setString()
PreparedStatement
executeUpdate()
executeQuery()
ResultSet
PreparedStatement:优点:语句预编译，执行效率高;可以避免注入攻击
使用Properties封装四大参数
连接:
使用连接池管理连接
集合
初始大小
扩充容量
最大容量
最小容量
使用结束，归还不是销毁
连接池:
DBCP
C3P0
Druid
使用C3P0连接池:
添加jar包：c3p0的核心包和依赖包，不要添加Oracle的依赖包
添加配置文件:配置文件名字不能改，位置只能放在类路径的根目录下(scr)
删除我们的db.properties
修改JdbcUtils类
事务处理:以后的Spring框架AOP管理事务
下订单:
订单表添加一条数据
订单条目表中添加多条数据
事务:一组操作，要执行都执行，不执行都不执行
四大特性:ACID
原子性:原子操作，一个整体
一致性:事务在执行前后，数据处于一个一致状态
转账
隔离性:事务在操作过程中，其他程序不能访问该数据
持久性:事务的执行结果最终会提交到数据库
数据库的事务操作默认是自动事务:
每一条独立的语句就是一个单独的事务
UI
Service
Dao
事务的概念本身是数据库的，真实的项目中事务是在业务层控制
JDBC中事务的提交和回滚的方法在Connection对象中,Java中控制一个事务必须使用同一个连接
Java中控制事务处理
标签：语句,JDBC,String,prepareStatement,基础,System,Connection,sql 来源： https://www.cnblogs.com/19322li/p/10770805.html