[大数据]JDBC操作Mysql数据库

一、JDBC快速了解

1. JDBC操作数据库流程：
   第一步：编写Java代码
   第二步：Java代码将SQL发送到MySQL服务端
   第三步：MySQL服务端接收到SQL语句并执行该SQL语句
   第四步：将SQL语句执行的结果返回给Java代码

2. 具体步骤

• 创建java工程，导入驱动jar包。
  在项目包目录下创建lib目录，然后复制jar包粘贴到lib中。
  并将jar包添加为库文件（模块有效Module Library）
  
  
  
  

如果是其他数据库就导入其他jar包

• 代码部分步骤（后面不会使用这个步骤）

1. 注册驱动，（后面不用写这一句，因为在MySQL 5之后的驱动包中，其实是可以不用调用Class.forName来加载mysql驱动的，因为mysql的驱动程序jar包中已经包含了java.sql.Driver配置文件，并在文件中添加了com.mysql.jdbc.Driver。）这里使用了java中反射（非常重要）的内容
   加载驱动类原理

Class.forName("com.mysql.jdbc.Driver");

2. 获取连接，（后面将被数据库连接池代替）

String url = "jdbc:mysql://127.0.0.1:3306/test?useSSL=false";
        String usename = "root";
        String password = "1234";
        Connection conn = DriverManager.getConnection(url, usename, password);

url语法：jdbc:mysql://ip地址(域名):端口号/数据库名称?参
数键值对1&参数键值对2…

3. 定义sql语句

tring sql="UPDATE Stu set money = money + 2000 where id =2";

4. 获取执行sql的对象 Statement （后面使用conn.prepareStatement(sql)）
   执行SQL语句需要SQL执行对象，而这个执行对象就是
   Statement对象

Statement stat = conn.createStatement();

5. 执行sql，并用count接收执行完后返回的 影响行数

int count = stat.executeUpdate(sql);

6. 处理结果（这里选择打印出来）

System.out.println(count);

7. 释放资源

stat.close();
conn.close();

二、JDBC的API详解

1. DriverManager(驱动管理类)作用：

• 注册驱动
  

• 连接数据库

2. Connection（数据库连接对象）作用：

• 获取执行 SQL 的对象

普通执行SQL对象

Statement createStatement()

预编译SQL的执行SQL对象：防止SQL注入

PreparedStatement prep = conn.prepareStatement(sql);
 int count = prep.executeUpdate();//这里不再需要传入sql语句

PreparedStatement重点应用：

String name = "zhangsan";
String pwd = "' or '1' = '1";
// SQL语句中的参数值，使用？占位符替代
String sql = "select * from user where username = 
? and password = ?";
// 通过Connection对象获取，并传入对应的sql语句
PreparedStatement pstmt = 
conn.prepareStatement(sql);
// 设置？的值
pstmt.setString(1,name);
pstmt.setString(2,pwd);

• 管理事务

/**
 * JDBC API 详解：Connection
 */
public class JDBCDemo3_Connection {
    public static void main(String[] args) throws 
Exception {
        //1. 注册驱动
        //Class.forName("com.mysql.jdbc.Driver");
        //2. 获取连接：如果连接的是本机mysql并且端口是默认
的 3306 可以简化书写
        String url = "jdbc:mysql:///db1?
useSSL=false";
        String username = "root";
        String password = "1234";
        Connection conn = 
DriverManager.getConnection(url, username, 
password);
        //3. 定义sql
        String sql1 = "update account set money = 
3000 where id = 1";
        String sql2 = "update account set money = 
3000 where id = 2";
        //4. 获取执行sql的对象 Statement
        Statement stmt = conn.createStatement();
        try {
            // ============开启事务==========
            conn.setAutoCommit(false);
            //5. 执行sql
            int count1 = stmt.executeUpdate(sql1);//
受影响的行数
            //6. 处理结果
            System.out.println(count1);
            int i = 3/0;
            //5. 执行sql
            int count2 = stmt.executeUpdate(sql2);//
受影响的行数
            //6. 处理结果
            System.out.println(count2);
            // ============提交事务==========
            //程序运行到此处，说明没有出现任何问题，则需求提
交事务
            conn.commit();
        } catch (Exception e) {
            // ============回滚事务==========
            //程序在出现异常时会执行到这个地方，此时就需要回
滚事务
            conn.rollback();
            e.printStackTrace();
        }
        //7. 释放资源
        stmt.close();
        conn.close();
	}
}

3. Statement对象的作用：

• 执行SQL语句。而针对不同类型的SQL语句使用的方法也不一样。
• 执行DDL、DML语句：executeUpdate(sql)
• 执行查询DQL语句：executeQuery(sql)

4. ResultSet（结果集对象）作用：

• 封装SQL查询语句DQL返回的结果

boolean  next()
将光标从当前位置向前移动一行 
判断当前行是否为有效行
方法返回值说明：
true  ： 有效行，当前行有数据
false ： 无效行，当前行没有数据
xxx  getXxx(参数)：获取数据
xxx : 数据类型；如： int getInt(参数) ；String getString(参
数)
参数
int类型的参数：列的编号，从1开始
String类型的参数： 列的名称 

package indi.wwz.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class JDBCDemo1 {
    public static void main(String[] args) throws Exception {
        //1
        //Class.forName("com.mysql.jdbc.Driver");
        //2
        String url = "jdbc:mysql://127.0.0.1:3306/test?useSSL=false";
        String usename = "root";
        String password = "1234";
        Connection conn = DriverManager.getConnection(url, usename, password);
        //3
        String sql="select * from stu;";
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        //光标向下移动一行，并且判断当前行是否有数据
        while (rs.next()){
//            int id = rs.getInt(1);
//            int money = rs.getInt(2);
//            String name = rs.getString(3);
//这里1，2，3分别代表id money name
            int id = rs.getInt("id");
            int money = rs.getInt("money");
            String name = rs.getString("name");
            System.out.println(id);
            System.out.println(money);
            System.out.println(name);
        }
        rs.close();
        stmt.close();
        conn.close();
    }
}

三、数据库连接池

druid配置详解

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql:///db1?
useSSL=false&useServerPrepStmts=true
username=root
password=1234
# 初始化连接数量
initialSize=5
# 最大连接数
maxActive=10
# 最大等待时间
maxWait=3000

使用druid的代码(固定)如下：

 * Druid数据库连接池演示
 */
public class DruidDemo {
    public static void main(String[] args) throws 
Exception {
        //1.导入jar包
        //2.定义配置文件
        //3. 加载配置文件
        Properties prop = new Properties();
        prop.load(new FileInputStream("jdbc-
demo/src/druid.properties"));
        //4. 获取连接池对象
        DataSource dataSource = 
DruidDataSourceFactory.createDataSource(prop);
        //5. 获取数据库连接 Connection
        Connection connection = 
dataSource.getConnection();
        System.out.println(connection); //获取到了连接
后就可以继续做其他操作了
       
 //System.out.println(System.getProperty("user.dir")
);
    }
}