Driver :接口,定义了各个驱动程序都必须要实现的功能,是驱动程序的抽象,通过操作java接口,就可以实现对各个驱动的操作
DriverManger:是Driver的管理类,用户通过Class.forName()的方式就可以向DriverManger注册一个驱动程序,然后通过DriverManger的getConnection(DB_URL,USER,PASS)方法调用该驱动程序建立到后端数据库的物理连接。
DB_URL:jdbc:mysql://127.0.0.1:3306/mysql是后端数据库的唯一标识符,应用程序通过该标识符即可唯一确定后端的某个数据库实例。它是由三部分组成:jdbc(协议):mysql(子协议)://127.0.0.1(主机):3306(数据库端口)/mysql(数据库)(子名称)
常用DB_URL格式:
MySQL:Jdbc:mysql://<ip>:<port>/database
ORACLE:jdbc:oracle:thin:@<ip>:<port>:database
SQL server:jdbc:microsoft:sqlserver://<ip>:<port>;DatabaseName=database
Connection:代表了java应用程序对后端数据库的一条物理连接,基于这条连接可以执行一些sql语句。Connection对象->Statement方法->ResultSet对象
Statement方法创建了一个Statement对象,是sql的容器,在这容器中可以进行select,delete,update等操作,容器中盛载sql语句,通过statement对象的executeQuery()方法可以执行数据库查询得到查询结果的集合,这个集合是用Resultet对象/Int值来表示的。
ResultSet对象代表了sql语句查询的结果,而ResultSet实际上是一个由行和列组成的二元表,其内部有指针指向当前对应的行记录,默认该指针指向第一行记录:
通过调用.next()方法将光标指向下一行,
通过调用.previous()方法将光标向前移动
通过调用.absolute()方法将光标直接定位到某一行
通过调用.beforeFirst()方法将光标直接移动到第一行的最前端,通过.next()方法返回第一行
通过调用.afterLast()方法将光标直接移动到最后一行的下一条记录
将光标调整到对应的行以后,然后获取对应的列的结果:
.getString(列名)
.getInt(列名)
JDBC构建步骤:
- 装载驱动程序
- 建立数据库连接
- 执行sql语句
- 获取执行结果
- 清理资源
//代码如下:
public class HelloJdbc {
static final String JDBC_DRIVER="";
static String DB_URL="jdbc:mysql://localhost/demo";
static final String USER="root";
static final String PASSWD="root";
public static void helloword()throws ClassNotFoundException{
Connection conn=null;
Statement sta=null;
ResultSet rs=null;
//加载驱动程序
Class.forName(JDBC_DRIVER);
//建立后端数据库连接
try {
conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
//执行sql语句
sta=conn.createStatement();
rs=sta.executeQuery("select name from student");
//获取执行结果
while(rs.next()) {
System.out.println("hello");
}
} catch (SQLException e) {
//异常处理
e.printStackTrace();
}finally {
//清理资源
try {
if(rs!=null) rs.close();
if(sta!=null) sta.close();
if(conn!=null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
业务场景:
- 过滤条件较弱,一次可能读出较多记录
- 读取数据库表中所有记录(海量数据读取)
异常分析:jvm有内容限制,读取数据超出限制,会得到内存溢出的异常
解决方法:游标提供一种客户端读取部分服务器端结果集的机制,允许分批读取sql查询的结果。
如何使用游标:
- 在DB_URL后添加useCursorFetch=true,开启游标
- PreparedStatement接口,继承自Statement,使用PrepareStatement替换Statement,PrepareStatement要求程序员在生成PrepareStatement时就要传入sql语句,而这个sql语句则是一个参数格式化的sql,即sql的过滤条件参数都是通过?的形式来表示,后续通过PrepareStatement的setString()和setInt()设置参数,然后进行执行。通过.setFetchSize()设置JDBC每次从服务器端取回的记录的数量
DB_URL:jdbc:mysql://<ip>:<port>/database?useCursorFetch=true
代码如下:
//加载驱动程序
Class.forName(JDBC_DRIVER);
//建立后端数据库连接
try {
conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
DB_URL=DB_URL+"useCursorFetch=true";
//执行sql语句
conn.prepareStatement("select name from student");
ptmt.setFetchSize(1);
rs=ptmt.executeQuery();
//获取执行结果
while(rs.next()) {
System.out.println("hello");
}
} catch (SQLException e) {
//异常处理
e.printStackTrace();
}finally {
//清理资源
try {
if(rs!=null) rs.close();
if(sta!=null) sta.close();
if(conn!=null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
-
大对象读取(图片等)
异常分析:内存溢出
解决方法:流方式
代码如下:try { Class.forName(JDBC_DRIVER); conn=DriverManager.getConnection(DB_URL, USER, PASSWD); String sql="select name from student"; ptmt=conn.prepareStatement(sql); rs=ptmt.excuteQuery(); while(rs.next()) { //获取对象流 InputStream in=rs.getBinaryStream("blog"); //将对象流写入对象 File f=new File(FILE_URL); OutputStream out=null; out=new FileOutputStream(f); int temp=0; while((temp=in.read())!=-1) { //边读边写 out.write(temp); } in.close(); out.close(); }}catch(SQLException e) { e.printStackTrace(); }finally {}
海量数据插入
原因分析:每次sql的update操作时都是一次客户端到服务端发送sql,接收sql的过程。每执行一次,就要发送一次,效率太低
解决方法:批处理,发送一次sql,发送多条数据
Statement->
-addBatch() 把sql打包成一个执行单元;batch是执行sql的单位
-executeBatch() 执行这批sql
-clearBatch() 清空batch中的sql语句
代码如下:
Set<String> users=new HashSet<String>();
users.add("");
users.add("");
Class.forName(JDBC_DRIVER);
try {
conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
sta=conn.createStatement();
for(String user:users) {
sta.addBatch("insert into user(username) values("+user+")");
}
sta.executeBatch();
sta.clearBatch();
}catch(SQLException e) {
e.printStackTrace();
}finally {
//如上,清理资源
}