JDBC
jdbc的目标是使java程序员使用JDBC可以连接任何提供了JDBC驱动程序的数据库系统
Java应用程序——>JDBC API——>JDBC驱动程序——>数据库
Java.sql.Driver接口是所有JDBC驱动程序需要实现的接口。
》这个接口是提供给数据库厂商使用的，不同数据库厂商提供不同的实现
》在程序中不需要直接访问实现了Driver接口的类，而是由驱动程序管理器类(java.sql.DriverManager)去调用这些Driver实现
数据库厂商必须实现的接口，能从中获取数据库的连接
/** * JDBC URL * jdbc:mysql://localhost:3306/test * * 对于oracle数据库连接： * jdbc:oracle:thin:@localhost:1521:sid * * 对于SQLserver数据库连接： * jdbc:miscrosoft:sqlserver//localhost:1433;DatabaseName=sid * * 对于MYSQL数据库连接： * jdbc:mysql://localhost:3306/sid */
连接数据库的步骤：
1、注册驱动(只做一次)
2、建立连接(Connection)
3、创建执行SQL的语句(Statment)
4、执行语句
5、处理执行结果(ResultSet)
6、释放资源
DriverManager 是驱动的管理类
1）可以通过重载的getConnection()方法获取数据库连接，较为方便
2）可以同时管理多个驱动程序：若注册多个数据库连接，则调用getConnection()方法时传入的参数不同，即返回不同的数据库连接
String driverClass = "oracle.jdbc.OracleDriver"; String url = "jdbc:oracle:thin:@localhost:1521:orcl"; String user = "scott"; String password = "123456"; //加载数据库驱动程序(对应的Driver实现类中有注册驱动的静态代码块) //DriverManager.registerDriver((Driver) Class.forName(driverClass).newInstance()); Class.forName(driverClass); Connection conn = DriverManager.getConnection(url, user, password); System.out.println(conn);
通过配置文件jdbc.properties获取数据库连接
String driverClass = "oracle.jdbc.OracleDriver";
String url = "jdbc:oracle:thin:@localhost:1521:orcl";
String user = "scott";
String password = "123456";
//读取配置文件信息
InputStream is = getClass().getClassLoader().getResourceAsStream("jdbc.properties");
Properties pro = new Properties();
//将读取的配置文件信息传入pro
pro.load(is);
//根据值进行查询赋值
driverClass = pro.getProperty("driverClass");
url = pro.getProperty("url");
user = pro.getProperty("user");
password = pro.getProperty("password");
//创建一个驱动对象 Class.forName() 加载数据库驱动
Driver driver = (Driver) Class.forName(driverClass).newInstance();
Properties info = new Properties();
info.put("user",user);
info.put("password",password);
//通过driverManager的getConnection()方法获取连接
Connection conn = DriverManager.getConnection(url, info);
return conn;
*增、删、改用Statement.executeUpdate来完成，返回整数(匹配的记录数)，这类操作相当简单。
*查询用Statement.executeQuery来完成，返回的是ResultSet对象，ResultSet中包含了查询的结果。
创建与数据库的连接的标准方式是在
DriverManager上调用方法getConnection().
statement(语句对象)
》executeUpdate(String sql):
执行SQL insert,update或delete语句，返回受影响的行的数目或零；返回值为int型
》executeQuery(String sql)
执行返回单个ResultSet的SQL语句；返回类型ResultSet
》execute(String sql)
执行可以返回多个结果的SQL语句。返回类型boolean,如果返回的是更新的数目，则返回false，如果返回ResultSet，则返回true。（不常用）
//1.获取数据库连接 Connection conn = getConnection(); //2.准备插入的sql语句 String sql = "insert into student values(3,'123','123')"; //3.执行插入 //（1）获取操作与SQL语句的Statement对象 Statement state = conn.createStatement(); //（2）调用Statement对象的executeUpdate(sql)执行SQL语句进行插入 int result = state.executeUpdate(sql); System.out.println(result); //4.关闭Statement对象 state.close(); //5.关闭连接 conn.close();
PreparedStatement
* 使用PreparedStatement
* 1)why?
①使用statement需要进行拼写SQL语句。很辛苦，而且容易出错。
②可以有效地禁止SQL注入。
——SQL诸如是利用某些系统没有对用户输入的数据进行充分的检查，而在用户输入，数据中注入非法的SQL语句段
——对于Java而言，要规范SQL注入，只要用PreparedStatement取代Statement就可以了。
SQL注入
String username = "a' OR PASSWORD = "; String password = "OR '1' = '1"; String sql = "SELECT * FROM USERS WHERE USERNAME = '" + username + "' AND " + "PASSWORD = '" + password + "'"; } select * from users where username = 'a' or password = 'and password = ' or '1' = '1'
《3》PreparedStatement能最大可能提高性能
* 2)PreparedStatement:是Statement的子接口，可以传入带占位符的SQL语句，而且
* 提供了补充占位符变量的方法。
*
* 使用PreparedStatement
* ①创建PreparedStatement：
* String sql = "INSERT INTO STUDENT VALUES(?,?,?,?,?)"
* PreparedStatement ps = conn.prepareStatement(sql);
*
* ②调用PreparedStatement的setXxx(int index,Object val)设置占位符的值。
* index值从1开始
*
* 3执行SQL语句：executeQuery()或executeUpdate().注意：执行时不再需要传入SQL语句
@Test
public void test2(){
Connection conn = null;
PreparedStatement preparedStatement = null;
try {
conn = getConnection();
String sql = "insert into examstudent values(?,?,?,?,?,?,?)";
preparedStatement = conn.prepareStatement(sql);
preparedStatement.setInt(1,11);
preparedStatement.setInt(2, 2);
preparedStatement.setString(3, "43121223113");
preparedStatement.setString(4,"1245523");
preparedStatement.setString(5,"yhs");
preparedStatement.setString(6,"dwd");
preparedStatement.setInt(7,3);
int re = preparedStatement.executeUpdate();
if(re ==1){
System.out.println("插入成功！！！");
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
release(preparedStatement, conn, null);
}
}
ResultSet
结果集读取数据的方法主要是getXXX(),他的参数可以使整数表示第几列(从1开始的)，还可以是列名。
返回的是对应的XXX类型的值。如果对应那列时空值，XXX是对象的话返回XXX型的空值，如果XXX是数字类型，如Float等返回0，boolean返回false
结果集，封装了使用JDBC进行查询的结果
1.调用Statement对象的executeQuery(sql)可以得到结果集
2.ResultSet返回的实际上就是一张数据表，有一个指针指向数据表的第一行的前面
可以使用next()方法检测下一行是否有效，若有效该方式返回true，且指针下移。
相当于Iterator对象的hasNext()和next()方法的结合体
3.当指针对位到一行时，可以通过getXxx(index)或getXxx(columnName)
获取每一列的值，例如：getInt(1),getString("name")
4.ResultSet:当然也需要进行关闭
单条数据查询：
Connection conn = getConnection();
Statement state = conn.createStatement();
String sql = "select * from student where id=1";
ResultSet rs = state.executeQuery(sql);
if(rs.next()){
int id = rs.getInt(1);
String name = rs.getString("name");
String password = rs.getString("password");
System.out.println(id);
System.out.println(name);
System.out.println(password);
}
conn.close();
state.close();
rs.close();
多条数据查询：
Connection conn = getConnection();
Statement state = conn.createStatement();
String sql = "select * from student";
ResultSet rs = state.executeQuery(sql);
while(rs.next()){
int id = rs.getInt(1);
String name = rs.getString("name");
String password = rs.getString("password");
System.out.print(id + " ");
System.out.print(name + " ");
System.out.println(password);
}
conn.close();
state.close();
rs.close();
封装查询多个对象的方法：
ResultSetMetaData：(解决红色部分)接口
1）what：是描述ResultSet的元数据对象，即从中可以获取到结果集有多少列，列名是什么....
2) how:
<1>得到ResultSetMetaData 对象：调用ResultSet的getMetaData()方法
<2>ResultSetMetaData有哪些好用的方法
>int getColumnCount(): SQL语句包含哪些列
>String getColumnLabel(int column):获取指定的列的别名，其中索引从1开始。
获取结果集每一列的别名
for(int i=0;i<rsmd.getColumnCount();i++){
String columnLabel = rsmd.getColumnLabel(i+1);
}
public <T> T testResultSetMetaData(Class<T> clazz,String sql,Object...args){
Connection conn = null;
PreparedStatement preparedstatement = null;
ResultSet resultset = null;
T entity = null;
try {
conn = getConnection();
preparedstatement = conn.prepareStatement(sql);
//对sql占位符进行赋值
for(int i=0;i<args.length;i++){
preparedstatement.setObject(i+1,args[i]);
}
resultset = preparedstatement.executeQuery();
ResultSetMetaData metaData = resultset.getMetaData();
Map<String,Object> map = new HashMap<String,Object>();
while(resultset.next()){
for(int i=0;i<metaData.getColumnCount();i++){
String columnLabel = metaData.getColumnLabel(i+1);
Object obj = resultset.getObject(i+1);
map.put(columnLabel, obj);
System.out.println(columnLabel + " " +obj);
}
}
if(map.size()>0){
entity = clazz.newInstance();
//遍历Map对象，利用反射为Class对象对应的属性赋值
for(Map.Entry<String, Object> entry : map.entrySet()){
String fieldName = entry.getKey();
Object value = entry.getValue();
BeanUtil
}
}
} catch (Exception e) {
// TODO: handle exception
}finally{
release(preparedstatement, conn, resultset);
}
return null;
}