越南网站建设,建网站选域名,网站建设的界面f分,建网站 行业 销售额【0】README
1#xff09; 本文部分文字描述和source code 均转自 core java volume 2 #xff0c; 旨在理解 java数据库编程——执行查询操作 的基础知识 #xff1b; 2#xff09; 本文和 java数据库编程——执行查询操作#xff08;二#xff09; 是姊妹篇#xff…【0】README
1 本文部分文字描述和source code 均转自 core java volume 2 旨在理解 java数据库编程——执行查询操作 的基础知识 2 本文和 java数据库编程——执行查询操作二 是姊妹篇 共同组成了 java数据库编程——执行查询操作的全部内容 for java数据库编程——执行查询操作二 please visit http://blog.csdn.net/PacosonSWJTU/article/details/50629580 3for database connection config, please visit https://github.com/pacosonTang/core-java-volume/blob/master/coreJavaAdvanced/chapter4/database.properties 【1】预备语句prepared statement
1 预备语句prepared statement 它是 Statement 语句对象 2problemsolution
2.1problem我们没有必要在每次开始一个查询是都建立新的查询语句 select books.price, books.title from books, publishers where books.publisher_id publishers.publisher_id and publishers.name the name from the list box 2.2solution 而是准备一个带有宿主变量的查询语句每次查询时只需要为该变量填入不同的字符串就可以反复多次使用该语句 String publisherQuery “select books.price, books.title ” “from books, publishers ” “where books. …. and publishers.name ?” 干货——预备语句中的宿主变量
3PreparedStatement set 方法 在执行预备语句前 必须使用 set 方法将变量 绑定到实际的值上 stat.setString(1, publisher) 除非使用 set 或者 clearParameters 方法否则所有宿主变量的绑定都不会改变 4价格更新操作可以有 update 语句实现
4.1请注意 我们调用的是 executeUpdate 方法 而非executeQuery 方法 因为 update 语句不返回结果集。 executeUpdate 的返回值为 被修改过的行数干货——executeUpdate 的返回值为 被修改过的行数 int r stat.executeUpdate();
5看个荔枝低效率的java 数据库查询代码 select books.price, books.title from books, booksAuthors, authors, publishers where authors.author_id booksAutors.author_id and booksAuthors.isbnbooks.isbn and books.publisher_idpublisher.publisher_id and authors.name? and publisher.name? 对以上java数据库查询代码的分析Analysis
A1在相关的 Connection对象关闭后 PreparedStatement 对象就变得无效了。 不过 许多数据库通常都会自动缓存预备语句。如果相同的查询被预备了两次 数据库通常会直接重用查询策略A2许多coders 都不喜欢用 如此复杂的sql 语句比较常见的方法是使用大量的 java 代码来迭代多个结果集 但是这种方法是低效的 干货——比较常见的方法是使用大量的 java 代码来迭代多个结果集 但是这种方法是低效的A3通常使用数据库的查询代码要比使用 java 代码好得多——这是数据库的一个优点 一般而言可以使用 sql 语句解决的问题就不要使用 java 程序 干货——一般而言可以使用 sql 语句解决的问题就不要使用 java 程序
6 利用预备语句插入和查询的荔枝
6.1for full source code, please visit https://github.com/pacosonTang/core-java-volume/blob/master/coreJavaAdvanced/chapter4/execute_select/MyGetPrimaryKey.java6.2key source code at a glance
public static Connection getConnection() throws IOException, SQLException{Properties prop new Properties();try(InputStream in Files.newInputStream(Paths.get(cur_dir database.properties))){prop.load(in);}String drivers prop.getProperty(jdbc.drivers);if(drivers ! null){System.setProperty(jdbc.drivers, drivers); // register drivers for accessing database }String url prop.getProperty(jdbc.url);String user prop.getProperty(jdbc.username);String pass prop.getProperty(jdbc.password);return DriverManager.getConnection(url, user, pass);}// PreparedStatement for query operationpublic static void main3(String[] args) throws SQLException, IOException{ try{try(Connection conn getConnection()){// String sql insert employee(name, salary, address) values(zhangsan,1000,beijing);String sql select * from employee where id ?;PreparedStatement stat conn.prepareStatement(sql);stat.setInt(1, 12);ResultSet rs stat.executeQuery();// attention for not writing stat.executeQuery(sql);while(rs.next()){System.out.println(rs.getInt(1) , rs.getString(2) , rs.getDouble(3) , rs.getString(4));}}}catch(Exception e){e.printStackTrace();}} // PreparedStatement for insert operationpublic static void main2(String[] args) throws SQLException, IOException{ try{try(Connection conn getConnection()){// String sql insert employee(name, salary, address) values(zhangsan,1000,beijing);String sql insert into employee(name,salary,address) values(?,?,?);//Statement stat conn.createStatement();PreparedStatement stat conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);String[] names {lisi, wangwu, zhaoliu};double[] salary {120, 110, 999};String[] address {chengdu, shanghai, shenzheng};for (int i 0; i address.length; i){// 除非使用 set 或者 clearParameters 方法否则所有宿主变量(?)的绑定都不会改变stat.setString(1, names[i]);stat.setDouble(2, salary[i]);stat.setString(3, address[i]);stat.executeUpdate();// attention for not writing stat.executeUpdate(sql);} sql select * from employee;ResultSet rs stat.executeQuery(sql);while(rs.next()){System.out.println(rs.getInt(1) , rs.getString(2) , rs.getDouble(3) , rs.getString(4));}}}catch(Exception e){e.printStackTrace();}}
其中 database.properties 文件内容如下后面不在累述 jdbc.driverscom.mysql.jdbc.Driver jdbc.urljdbc:mysql://localhost:3306/testCoreJava jdbc.usernameroot jdbc.passwordroot 6.3relative printing results as follows 【2】读写 LOBLarge OBject
1大对象LOB许多数据库还存储大对象 如图片和其它数据 干货——LOB定义
1.1BLOBCLOB二进制大对象称为BLOB 字符型大对象被称为 CLOB1.2要读取 LOB 需要执行 select 语句然后在 ResultSet 上调用 getBlob 或getClob 方法 这样就可以获得 Blog 或 Clob 类型的对象了1.3要从 Blob 中获取二进制数据可以调用 getBytes 或 getInputStream 1.4获取Clob的字符数据类似地 如果获取了 Clob对象 那么就可以调用getSubString 或 getCharacterStream方法来获取其中的字符数据
2看个荔枝 如何将图片保存到数据库和如何从数据库获取图片并保存到本地 干货荔枝——如何向数据库插入图片和从数据库中获取图片 Attention
A1通过JDBC将图片插入到数据库和从数据库取出图片本保存到本地的idea 参见 http://blog.csdn.net/pacosonswjtu/article/details/50628628A2荔枝中 关于存储图片到本地的代码转自 http://www.codejava.net/java-se/jdbc/read-file-data-from-database-using-jdbcA3for full source code, please visit : https://github.com/pacosonTang/core-java-volume/blob/master/coreJavaAdvanced/chapter4/execute_select/JDBCReadWriteImage.javaA4key source code at a glance
package com.corejava.chapter4;import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;public class JDBCReadWriteImage
{private static String cur_dir System.getProperty(user.dir) File.separator com File.separator corejava File.separator chapter4 File.separator;// insert and select blob objpublic static void main(String[] args){try{try(Connection conn getConnection()){// inserting starts.String sql insert into employee(name, headportrait) values(?,?);PreparedStatement insertStat conn.prepareStatement(sql);insertStat.setString(1, imageAdmin); insertStat.setBlob(2, new FileInputStream(new File(cur_dirjdbc.jpg)));if(insertStat.executeUpdate() ! 0){System.out.println(successful inserting!);}else{System.out.println(failed inserting!);}// inserting ends.// query starts.sql select headportrait from employee where name imageAdmin;Statement stat conn.createStatement(); ResultSet rs stat.executeQuery(sql);int i 1;while(rs.next()){Blob blob rs.getBlob(1);InputStream instream blob.getBinaryStream();OutputStream outstream new FileOutputStream(new File(cur_dir blog (i) .jpg));byte[] buffer new byte[1024];int readLength -1;while((readLength instream.read(buffer)) ! -1){outstream.write(buffer, 0, readLength);}System.out.println(successful query and saving the file !);}// query ends.stat.close();conn.close();}}catch(Exception e){e.printStackTrace();}}public static Connection getConnection() throws IOException, SQLException{Properties prop new Properties();try(InputStream in Files.newInputStream(Paths.get(cur_dir database.properties))){prop.load(in);}String drivers prop.getProperty(jdbc.drivers);if(drivers ! null){System.setProperty(jdbc.drivers, drivers); // register drivers for accessing database }String url prop.getProperty(jdbc.url);String user prop.getProperty(jdbc.username);String pass prop.getProperty(jdbc.password);return DriverManager.getConnection(url, user, pass);}
}A5 relative printing results as follows:
