本文主要是介绍java/jdbc数据库操作、事务处理、批处理、分页查询、元数据、，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
脏读，不可重复读，幻读是由于数据库事务的隔离性导致的问题。
脏读：一个事务读取到了其它未提交事务操作的记录。
不可重复读：一个事务A内，首次查询到一条相同记录，然后事务B修改该条记录并提交，事务A再次执行相同查询，得到了事务B更新后的结果，事务A两次相同的查询，却得到了不同的结果，这个叫做不可重复读。是由于已提交事务B对事务A造成了影响（对于查询操作）。
幻读：一个事务A内，先查询某条不存在的记录，然后插入这条记录。在事务A结束之前，有个事务B抢先把这条记录插入并提交，导致事务A插入失败。这种情况叫做幻读。是由于已提交事务B对事务A造成了影响（对于插入操作）。
JDBC:是一套标准，用java取链接数据库，是由一些接口和类组成；JDBC通过不同的驱动去操作不同的数据库。
主要有2个包：java.sql.* DriveManager类 Statement PrepareStatement ResultSet CallableStatement(用于调用存储过程)
javax.sql.* DataSource接口
1。注册驱动
DriverManager.registerDriver(new Driver);//这个会加载两次驱动，依赖驱动的jar包，
Class,forName("com.mysql.jdbc.Driver");//反射实现加载驱动，只加载一次，降低耦合，不依赖驱动jar包。
2.获取链接对象，这时就通过url确定了链接的是mysql数据库，而不是其他的数据库
Connectopn conn=DriveManger.getConnection("jdbc:mysql://localhost:3306/first","root","abc");
3.获取操作sql语句的Statement
Statement st=conn.createStatement();
4.操作的sql
String sql="select *from user";
5.执行sql得到结果集，DML语句（insert update delete）用excuteUpdate()，仅用返回值非0来判断语句是否执行成功；
DQL(select)用executeQuery（sql），excute（）可以执行任何语句。
Result rs=st.executeQuery(sql);
6.遍历结果集
boolean flag=rs.next();//向下移动，如果为true代表有吓一条记录。
while(rs.next()){
int id=rs.getInt("id");或者rs.getInt(1);1表示第一个字段。
}
7.释放资源
rs.close();
st.close();
conn.close();
***DriverManager
管理一组JDBC的驱动程序的基本服务；
********批处理操作：
addBatch(sql);//sql添加到批处理
excuteBatch();//批量执行
clearBatch();//清空批处理
****ResultSet结果集
getObject（）可以获取任意类型；
getInt（）
getString（）；可以获取任何类型的数据类型，结果会变成String；
getDate（）
getDouble（）；
参数是字段名或者列号
当结果集只有一条或者没有数据时，用if 不要用while遍历
*****资源的释放，为保证资源释放一定能执行，要放在finally中；
****获取abc.properties中的内容：
String username=ResourceBundle.getBundle("abc").getString("username");
*****JDBCUTIL的抽取：把获取注册驱动放到static静态块，把参数放到properties中，也放到static静态块中获取。
****滚动结构集：默认得到的rs.next结果集是只能向下遍历，滚动结果集是滚动到指定的行号；
定位rs.absolute(3)结果集定位某一行
********获取数据库的元数据：
//获取数据库的元数据public void getData(String tablename)throws Exception{String sql="select *from " + tablename;Connection conn = DBUtil.getConnection();Statement stmt = conn.createStatement();ResultSet rs = stmt.executeQuery(sql);try {//获取数据库的元数据DatabaseMetaData dmd=(DatabaseMetaData) conn.getMetaData();//数据库名String dbname=dmd.getDatabaseProductName();//数据库的版本号int version=dmd.getDatabaseMajorVersion();//数据库的连接地址String url=dmd.getURL();//数据库用户名dmd.getUserName();//获取结果集元数据ResultSetMetaData rsmd=(ResultSetMetaData) rs.getMetaData();//获取列数int colCount=rsmd.getColumnCount();//获取第i列的字段名,jdbc中字段的序号从1开始；String colname= rsmd.getColumnName(1);} catch (Exception e) {// TODO: handle exception}}
********jdbc操作数据库的常用操作：
连接数据库的工具类：
package util;import java.io.File;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;/*** @author HaokeMaster 数据连接和关闭的工具类* commmand +shift+o 自动导包*/
public class DBUtil {private static String url;private static String dbUser;private static String dbPassword;//获取属性文件中的内容public static void getPropertiesParam(String filename) {
// //***方法1。在classpath的目录下（即在src的目录下）用getclassload方法获取
// Properties propes=new Properties();
// try {
// InputStream fis = DBUtil.class.getClassLoader().getResourceAsStream(filename);
// //加载输入流指定的文件
// propes.load(fis);
// //获取文件中对应的键的值
// url=propes.getProperty("url");
// dbUser=propes.getProperty("dbUser");
// dbPassword=propes.getProperty("dbPassword");
//
// System.out.println(url);
// }catch (Exception e) {
//
// }//*****方法2.不在classpath的目录下（即不在src的目录下），必须使用完整路径Properties propes=new Properties();File file=new File(filename);try {FileInputStream fis=new FileInputStream(file);//加载输入流指定的文件propes.load(fis);//获取文件中对应的键的值url=propes.getProperty("url");dbUser=propes.getProperty("dbUser");dbPassword=propes.getProperty("dbPassword");System.out.println(url);}catch (Exception e) {}}// 建立数据库连接public static Connection getConnection() throws Exception {DBUtil.getPropertiesParam("/Users/HaokeMaster/Desktop/javatest01/First/src/mysqlUse.properties");//对应上面的方法2；不在classpath的目录下（即在src的目录下），这个必须是完整路径
// DBUtil.getPropertiesParam("mysqlUse.properties");//对应上面的方法1；在classpath的目录下（即在src的目录下），直接写文件名加后缀Connection conn = null;try {Class.forName("com.mysql.cj.jdbc.Driver");// 加载MYSQL JDBC驱动程序
// conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/firstDB", "root",
// "1234567890");// 连接URL为 jdbc:mysql//服务器地址:端口号/数据库名 ，后面的2个参数分别是登陆用户名和密码conn = DriverManager.getConnection(url, dbUser,dbPassword);} catch (Exception e) {e.printStackTrace();throw e;}return conn;}// 关闭数据库连接public static void close(Connection conn){if(conn!=null){try {conn.close();} catch (SQLException e) { e.printStackTrace();} }}}数据库操作接口：
package dao;import java.util.List;import entity.User;/*** @author HaokeMaster*操作数据库接口*/
public interface UserDAO {public List<User> findAll()throws Exception;//查询所用用户的信息public void delete(int id)throws Exception;//删除用户信息public void save(User e)throws Exception;//增加保存用户信息public void update(User e)throws Exception;//更新一个用户的信息public User findById(int id)throws Exception;//一条记录
public void getData(String tablename)throws Exception;//获取数据库的源数据}数据库操作接口实现类：
package dao.impls;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;import com.mysql.cj.jdbc.DatabaseMetaData;
import com.mysql.cj.jdbc.result.ResultSetMetaData;
import com.mysql.cj.protocol.x.ResultMessageListener;import dao.UserDAO;
import entity.User;
import util.DBUtil;public class UserDAOone implements UserDAO {// 添加@Overridepublic void save(User e) throws Exception {Connection conn = DBUtil.getConnection();//使用Statement，sql语句在执行的时候传递；使用PreparedStatement，sql语句在生成语句对象的时候传递PreparedStatement prep = conn.prepareStatement("insert into " + "PEOPLE(id,name,age,phoneNum) " + "values(null,?,?,?)");prep.setString(1, e.getName());//1,2,3表示的是第一第二第三个参数prep.setInt(2, e.getAge());prep.setString(3, e.getPhoneNum());prep.executeUpdate();DBUtil.close(conn);}// 根据id删除@Overridepublic void delete(int id) throws Exception {Connection conn = DBUtil.getConnection();PreparedStatement prep = conn.prepareStatement("delete from PEOPLE where id=?");//预编译语句对象prep.setLong(1, id);prep.executeUpdate();DBUtil.close(conn);}// 更新@Overridepublic void update(User e) throws Exception {Connection conn = DBUtil.getConnection();PreparedStatement prep = conn.prepareStatement("update PEOPLE " + "set name=?,age=?,phoneNum=? " + "where id=?");prep.setString(1, e.getName());prep.setInt(2, e.getAge());prep.setString(3, e.getPhoneNum());prep.setInt(4, e.getId());prep.executeUpdate();DBUtil.close(conn);}//根据id查询一条记录@Overridepublic User findById(int id) throws Exception {Connection conn = DBUtil.getConnection();PreparedStatement prep = conn.prepareStatement("select * " + "from PEOPLE where id=?");prep.setInt(1, id);ResultSet rs = prep.executeQuery();User e = null;if (rs.next()) {e = new User();e.setName(rs.getString("name"));e.setId(rs.getInt("id"));e.setAge(rs.getInt("age"));e.setPhoneNum(rs.getString("phoneNum"));}DBUtil.close(conn);return e;}// 查询所有@Overridepublic List<User> findAll() throws Exception {Connection conn = DBUtil.getConnection();Statement stmt = conn.createStatement();ResultSet rs = stmt.executeQuery("select * from PEOPLE");List<User> users = new ArrayList<User>();while (rs.next()) {User e = new User();e.setName(rs.getString("name"));e.setId(rs.getInt("id"));e.setAge(rs.getInt("age"));e.setPhoneNum(rs.getString("phoneNum"));users.add(e);}DBUtil.close(conn);return users;}//获取数据库的元数据public void getData(String tablename)throws Exception{String sql="select *from " + tablename;Connection conn = DBUtil.getConnection();Statement stmt = conn.createStatement();ResultSet rs = stmt.executeQuery(sql);try {//获取数据库的元数据DatabaseMetaData dmd=(DatabaseMetaData) conn.getMetaData();//数据库名String dbname=dmd.getDatabaseProductName();//数据库的版本号int version=dmd.getDatabaseMajorVersion();//数据库的连接地址String url=dmd.getURL();//数据库用户名dmd.getUserName();//获取结果集元数据ResultSetMetaData rsmd=(ResultSetMetaData) rs.getMetaData();//获取列数int colCount=rsmd.getColumnCount();//获取第i列的字段名,jdbc中字段的序号从1开始；String colname= rsmd.getColumnName(1);} catch (Exception e) {// TODO: handle exception}}
}********事务的处理：
Class.forName("com.mysql.cj.jdbc.Driver"); // 加载MYSQL JDBC驱动程序
Connection connect = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/firstDB", "root",
"1234567890");
// 连接URL为 jdbc:mysql//服务器地址:端口号/数据库名 ，后面的2个参数分别是登陆用户名和密码
// 创建一个 Statment对象
//使用Statement，sql语句在执行的时候传递；
Statement stmt = connect.createStatement();
ResultSet rs = stmt.executeQuery("select * from PEOPLE");
使用PreparedStatement，sql语句在生成语句对象的时候传递
PreparedStatement prep = conn.prepareStatement("delete from PEOPLE where id=?");//预编译语句对象
prep.setLong(1, id);
prep.executeUpdate();
connect.setAutoCommit(false);//jdbc默认是自动提交；这里关闭自动提交
connect.commit();//提交数据
connect.rollback();//回滚数据
*****批处理：
***** PreparedStatement实现批处理：Connection conn = null;PreparedStatement st = null;ResultSet rs = null;try{conn = DBUtil.getConnection();String sql = "insert into testbatch(id,name) values(?,?)";st = conn.prepareStatement(sql);for(int i=1;i<1000008;i++){ //i=1000 2000st.setInt(1, i);st.setString(2, "aa" + i);st.addBatch();//添加批处理if(i%1000==0){st.executeBatch();//执行批处理st.clearBatch();//清除批处理}}st.executeBatch();}catch (Exception e) {e.printStackTrace();}finally{DBUtil.close(conn);rs=null;st=null;}***** Statement实现数据库批处理：这个的缺点是要多写很多重复的语句。Connection conn = null;Statement st = null;ResultSet rs = null;try{conn = DBUtil.getConnection();//建立数据库连接String sql1 = "insert into testbatch(id,name) values(1,'aaa')";String sql2 = "insert into testbatch(id,name) values(2,'bbb')";String sql3 = "insert into testbatch(id,name) values(3,'CCC')";st = conn.createStatement();//添加要批量执行的SQLst.addBatch(sql1);st.addBatch(sql2);st.addBatch(sql3);//执行批处理SQL语句st.executeBatch();//清除批处理命令st.clearBatch();}catch (Exception e) {e.printStackTrace();}finally{conn=null;st=null;rs=null;}
*****分页查询：
createStatement中三个参数用法：https://blog.csdn.net/u012690202/article/details/73850490
1.基于缓存的分页查询：一次性把数据全部取出来放在缓存中，根据要看的页数和每页的记录数pageSize来计算要把那些数据显示出来。适合比较小的数据量，数据量大时，对内存的压力很大。
公式：n是第几页；pageSize是每次查询的数据量
(n-1)*pageSize+1 - (n-1)*pageSize+1+pageSize-1（就是 n*pageSize）
//分页查询，page是第几页，pageSize是每页的记录数量
public void getPage(int pageSize,int page)throws Exception{
int begin =(page-1)*pageSize+1;// 记录的起点
String sql="select *from PEOPLE";
Connection conn = DBUtil.getConnection();
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);//第一个参数是表示可滚动的结果集，可以跳步；第二个参数设置并发性其他用户只读
ResultSet rs = stmt.executeQuery(sql);
//指针定位到绝对位置，第三条记录
rs.absolute(3);
//定位到相对位置，相对于上一个的位置基础上加5.到第8条记录
rs.relative(5);
//下一条,第9条记录
rs.next();
//前一条，第8条记录
rs.previous();
2.频繁的查询数据库，内存压力小。
********存储过程
*******函数
这篇关于java/jdbc数据库操作、事务处理、批处理、分页查询、元数据、的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
