JAVA Database Connectivity java 数据库连接
###使用JDBC的基本步骤
1. 注册驱动
`DriverManager.registerDriver(new com.mysql.jdbc.Driver());<这里需要抛出异常>`
1. 建立连接
//DriverManager.getConnection("jdbc:mysql://localhost/test?user=monty&password=greatsqldb");
(参数一: 协议 访问的数据库,参数二:用户名,参数三:密码)
<下面例子:>
Connection coon = DriverManager.getConnection("jdbc:mysql://localhost/student", "root", "123456");
3.创建statement,跟数据库打交道,一定需要这个对象
`Statement st = conn.createStatement();`
4.执行查询,得到结果集
执行sql,得到ResultSet
String sql = "select * from 你的表名";
ResultSet rs = st.executeQuery(sql);
通过遍历 :
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
......
System.out.println("输出语句");
}
*****记得释放资源
if(rs !=null){
try{
rs.close();
}catch (SQLException sqlEx){} //ignore
rs = null;
}
.....
###JDBC工具类构建
1.资源释放工作的整合
2.驱动防二次注册
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Driver 这个类里面有静态代码块，一上来就执行了，所以等同于我们注册了两次驱动。 其实没这个必要的。
//静态代码块 ---> 类加载了，就执行。 java.sql.DriverManager.registerDriver(new Driver());
最后形成以下代码即可
Class.forName("com.mysql.jdbc.Driver");
3.使用properties配置文件
1.在src底下声明一个文件xxx.properties,里面的内容如下:
driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost/数据库名
name=root
password=123456
2.在工具类里面,使用静态代码块,读取属性
还有一段配置如下:
static String driverClass = null;
static String url =null;
static String name = null;
static String password = null;
static{
try{
//1.创建一个属性配置对象
Properties.properties = new Properties();
//InputStream is = new FileInputStream("xxx.properties");//对于文件位于工程根目录
//使用类加载器,去读取src底下的资源文件.后面再servlet //对应文件位于src目录底下
InputStream is = JDBCUtil.class.getClassLoader().getResourceAsStream("xxx.properties");
//导入输入流
properties.load(is);
//读取属性
driverClass = properties.getProperty("driverClass");
url = properties.getProperty("url");
name = properties.getProperty("name");
password = properties.getProperty("password");
}catch (Exception e){
e.printStackTrace();
}
}
###数据库的CRUD sql
* **insert**
` INSERT INTO 表名(NAME,age)VALUES(‘wangqiang‘,28)`
` INSERT INTO 表名 VALUES(NULL,‘wangqiang‘,28)`
//1.获取连接对象
conn = JDBCUtil.getConn();
// 2. 根据连接对象，得到statement
st = conn.createStatement();
//3. 执行添加
String sql = "insert into t_stu values(null , ‘aobama‘ , 59)";
//影响的行数， ，如果大于0 表明操作成功。 否则失败
int result = st.executeUpdate(sql);
if(result >0 ){
System.out.println("添加成功");
}else{
System.out.println("添加失败");
}
* **delete**
DELETE FROM 表名 WHERE id = 1
//1.获取连接对象
Connection conn = JDBCUtil.getConn();
//2.根据连接对象,得到statement
st = conn.createStatement();
//3
String sql = "delete from 表名 where id = 1";
//影响的行数， ，如果大于0 表明操作成功。 否则失败
int result = st.executeUpdate(sql);
if(result > 0 ){
System.out.println("删除成功");
}else{
System.out.println("删除失败");
}
* **query**
`SELECT * FROM 表名`
Statement st = null;
ResultSet rs = null;
Connection conn = null;
//1.获取连接对象
conn = JDBCUtil.getConn();
//2.根据连接对象,得到statement对象
st = conn.createStatement();
//3.执行sql,返回ResultSet
String sql = "Select * from 表名";
ResultSet rs = st.executeQuery(sql);
//4.遍历结果集
while(rs.next()){
String name = rs.getString("name");
...
System.out.println("name=" name "...");
}
* **update**
`UPDATE 表名 SET age = 18 WHERE id = 1;`
//1.获取连接对象
conn = JDBCUtil.getConn();
//2.根据连接对象,得到statement对象
st = conn.createStatement();
String sql = "update 表名 set age = 18 where id = 1";
int result = st.executeUpdate(sql);
if(result >0 ){
System.out.println("更新成功");
}else{
System.out.println("更新失败");
}
###使用单元测试,测试代码
1.定义一个类,TestXXX,里面定义方法testXXX.
2.添加junit的支持
右键工程 --- add Library---Junit---Junit4
3.在方法的上面加上注解,其实就是一个标记
@Test
public void testQuery(){
...
}
4.光标选中方法名字,然后右键执行单元测试.或者是打开outline视图,然后选择方法右键执行
###Dao模式
>Data Access Object 数据访问对象
1.新建一个dao的接口,里面声明数据库访问规则
//定义数据库的方法
public interface UserDao(){
//查询所有
void findAll();
}
2.新建一个dao的实现类
public class UserDaoImpl implements UserDao{
@Override
public void findAll() {
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try {
//1. 获取连接对象
conn = JDBCUtil.getConn();
//2. 创建statement对象
st = conn.createStatement();
String sql = "select * from t_user";
rs = st.executeQuery(sql);
while(rs.next()){
String userName = rs.getString("username");
String password = rs.getString("password");
System.out.println(userName "=" password);
}
} catch (Exception e) {
e.printStackTrace();
}finally {
JDBCUtil.release(conn, st, rs);
}
}
}
3.直接使用实现
public class TestUser {
@Test
public void demo1(){
UserDao userDao = new UserDaoImpl();
userDao.findAll();
}
}
##Statement安全问题
1.Statement执行,其实是拼接sql语句的.先拼接sql语句,然后在一起执行.
String sql = "select * from t_user where username=‘" username "‘ and password=‘" password "‘";
UserDao dao = new UserDaoImpl();
dao.login("admin", "100234khsdf88‘ or ‘1=1");
SELECT * FROM t_user WHERE username=‘admin‘ AND PASSWORD=‘100234khsdf88‘ or ‘1=1‘
前面先拼接sql语句， 如果变量里面带有了 数据库的关键字，那么一并认为是关键字。 不认为是普通的字符串。
rs = st.executeQuery(sql)
###PrepareStatement
>该对象就是替换前面的statement对象
1.相比较以前的statement， 预先处理给定的sql语句，对其执行语法检查。 在sql语句里面使用 ? 占位符来替代后续要传递进来的变量。 后面进来的变量值，将会被看成是字符串，不会产生任何的关键字。
sql = "insert into t_user values(null , ? , ?)";
ps = conn.prepareStatement(sql);
//给占位符赋值 从左到右数过来，1 代表第一个问号， 永远从1开始。
ps.setString(1, userName);
ps.setString(2, password);
##总结:
1.JDBC入门
2.抽取工具类 ###
3.Statement CRUD###
演练crud
4.Dao模式###
声明与实现分开
5.PrepareStament CRUD###
预处理sql语句,解决上面statement出现的问题