java/jdbc数据库操作、事务处理、批处理、分页查询、元数据、

本文主要是介绍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);