1. JDBC的介绍
jdbc为java开发者使用数据库提供了统一的编程接口，它由一组java类和接口组成。
访问数据库的流程
常用接口：- 一般针对java开发使用 Driver接口就行 ，- 在连接数据库时，需要装载特定厂商的数据驱动程序：
MySQL：Class.forname(‘com.mysql.jdbc.Driver’);
Oracle：Class.forname(‘oracle.jdbc.driver.OracleDriver’);
2.JDBC重要的API（以MySQL为例）
建立连接：
@Test
public void getConnect(){
try {
//加载驱动
Class.forName("com.mysql.jdbc.Driver");
//获取连接
String url="jdbc:mysql://localhost:3306/library";
String user="root";
String password="123456";
Connection connection = DriverManager.getConnection(url, user, password);
} catch (Exception e) {
e.printStackTrace();
}
}Statement
注意：这里Statement- 用于执行静态SQL语句并返回它所生成的结果对象，这里的Statement有三个类：
- Statement由createStatement创建，用于发送简单的SQL语句。（不带参）
- PreparedStatement：继承自Statement父类，由preparedStatement创建，用于发送含有一个或多个输入参数的SQL语句。PreparedStatement对象比Statement对象效率更高，并且可以防止SQL注入。
- CallableStatement:继承自PreparedStatement。由方法prePareCall创建，用于调用存储。
常用的Statement的方法有：
- execute（）：运行语句，返回是否有结果集
- executeQuery（）：运行select语句，返回ResultSet结果集
- executeUpdate（）：运行insert/update/delete操作，返回影响的行数
相关代码：
@Test
public void testStatement() throws SQLException {
//创建Statement
Statement statement = connection.createStatement();
String sql="select * from book";
boolean isNull= statement.execute(sql);
//创建PreparedStatement
sql="select * from book";
PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
ResultSet resultSet = preparedStatement1.executeQuery();
//PreparedStatement防止SQL注入,这里的?表示占位符
sql="select * from book where bid = ?";
PreparedStatement preparedStatement2 = connection.prepareStatement(sql);
preparedStatement2.setObject(1,2);
preparedStatement2.executeQuery();
}ResultSet
描述：ResultSet 主要是由executeQuery（）方法执行返回
读取数据的流程图：
@Test
public void testStatement() throws SQLException {
//创建PreparedStatement
String sql = "select * from book";
PreparedStatement preparedStatement1 = connection.prepareStatement(sql);
ResultSet resultSet = preparedStatement1.executeQuery();
while(resultSet.next()){ //表示是否还有下一个
System.out.println("bid"+resultSet.getInt(1));
System.out.println("bname"+resultSet.getString(2));
System.out.println("author"+resultSet.getString(3));
}
}jdbc的批处理
-
注意：如果使用大量的批处理时，建议使用statement，因为preparedstatement的预编译空间有限，当数据量特别大时，会发生异常。
例：@Test public void testStatement() throws SQLException { //创建Statement Statement statement = connection.createStatement(); for (int i = 0; i < 50; i++) { //获得当前的系统时间 long timestamp = System.currentTimeMillis(); String sql = "insert into t_date(t_time,t_id) values(" + timestamp + "," + i + ")"; //为批处理添加执行的SQL语句 statement.addBatch(sql); } //执行批处理 statement.executeBatch(); //提交事务 connection.commit(); }jdbc的事务
@Test public void testTransaction() { //取消自动提交 try { connection.setAutoCommit(false); //插入一条DML语句 PreparedStatement stetm1 = connection.prepareStatement("insert into book values(1001,'朝花夕拾','鲁迅')"); stetm1.execute(); //插入另条DML语句 PreparedStatement stetm2 = connection.prepareStatement("insert into book values(1001,'海贼王','尾田一郎')"); stetm2.execute(); //提交 connection.commit(); } catch (SQLException e) { try { //失败后自动回滚 connection.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } e.printStackTrace(); } }CLOB操作：
用于存储大量的文本数据，大字段的操作常常以流的方式处理。而非一般的字段一次读取即可。
//代码实现：
public class ReadAndWriteClob {
public static void main(String[] args) {
//获取数据库连接
try {
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/library",
"root",
"123456");
//clob字段插入
//表：user_info
//字段：name varchar , introduce clob
String sql = "insert into user_info values(?,?)";
PreparedStatement prepared1 = conn.prepareStatement(sql);
//插入数据
prepared1.setObject(1, "user1");
//设置插入文本对象，第二个参数是一个输入流，直接读取文件
prepared1.setClob(2,new BufferedReader(
new InputStreamReader(
new FileInputStream("src/a.txt"))));
prepared1.execute();
//clob字段读取
sql="select * from user_info";
PreparedStatement prepared2 =conn.prepareStatement(sql);
ResultSet resultSet = prepared2.executeQuery();
while(resultSet.next()){
Clob introduce = resultSet.getClob("introduce");
Reader characterStream = introduce.getCharacterStream();
int temp=0;
while((temp=characterStream.read())!=-1){
System.out.print((char)temp);
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}BLOB操作：
用于存储大量的二进制数据，二进制可以存入任何类型的文件（音频、视频等等..）。
//代码实现
public class ReadAndWriteClob {
public static void main(String[] args) {
//获取数据库连接
try {
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/library",
"root",
"123456");
//clob字段插入
//表：user_info
//字段：name varchar , headImg blob
String sql = "insert into user_info values(?,?)";
PreparedStatement prepared1 = conn.prepareStatement(sql);
//插入数据
prepared1.setObject(1, "user1");
//设置插入图片对象，第二个参数是一个基本输入流
prepared1.setBlob(2,new FileInputStream("src/a.jpg"));
prepared1.execute();
//clob字段读取
sql="select * from user_info";
PreparedStatement prepared2 =conn.prepareStatement(sql);
ResultSet resultSet = prepared2.executeQuery();
while(resultSet.next()){
Blob headImg = resultSet.getBlob("headImg");
//获取的是基本的流，
InputStream binaryStream = headImg.getBinaryStream();
int len=0;
byte flush []=new byte [1025];
OutputStream os=new FileOutputStream(new File("d:\\c.jpg"));
while((len=binaryStream.read(flush))!=-1){
os.write(flush,0,len);
os.flush();
}
os.close();
binaryStream.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}对jdbc的封装
这里需要加载配置文件：
代码实现：
public class jdbcUtils {
private static Properties pro;
static {
try {
pro = new Properties();
InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("dbproperties.properties");
pro.load(in);
Class.forName(pro.getProperty("driver"));
} catch (Exception e) {
e.printStackTrace();
}
}
//建立与数据库的连接
public static Connection getMySQLConn(){
try {
return DriverManager.getConnection(pro.getProperty("url"),
pro.getProperty("user"),
pro.getProperty("password"));
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
/**
* 关闭顺序：resultSet --preparStatement -- Connection
* 在关闭时，不能讲这三者的close()写在同一个try{}catch{}中
*/
public static void close(Statement stem,ResultSet rs,Connection conn){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(stem!=null){
try {
stem.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}原文地址：http://blog.51cto.com/14048416/2344705
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。