JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC为数据库开发人员提供了一个标准的API,使数据库开发人员能够用纯 Java API 编写数据库应用程序,并且可跨平台运行,并且不受数据库供应商的限制。其优点:

  • 操作便捷:开发人员不需要再使用复杂的驱动器调用命令和函数;
  • 可移植性强:JDBC支持不同的关系数据库
  • 通用性好:JDBC-ODBC桥接驱动器将JDBC函数换成ODBC;
  • 面向对象:可以将常用的JDBC数据库连接封装成一个类,在使用的时候直接调用即可
package DAO;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map; import com.mysql.jdbc.Statement; public class JDBC {
protected Connection conn;
protected Statement statement; public static Connection getConnection() throws Exception {
Connection connection = null; // 创建用于连接数据库的Connection对象
try {
Class.forName("com.mysql.jdbc.Driver");// 加载Mysql数据驱动
/**
* 127.0.0.1指本机,若是链接远程服务机器,则填写远程机器的ip 3306 mysql默认的端口号 test 数据库名称
* user 数据库用户名称 password 密码
*/
connection = DriverManager.getConnection(
"jdbc:mysql://127.0.0.1:3306/test", "user", "password");// 创建数据连接 } catch (Exception e) {
e.printStackTrace();
throw new Exception("链接mysql数据失败");
}
return connection; // 返回所建立的数据库连接
} /**
* 向mysql插入数据记录 返回插入数据的个数
*
* @param sql
* 要插入的sql语句
* @return count 插入数据的个数
* @throws Exception
*/
public int insert(String sql) throws Exception {
conn = getConnection(); // 连接到数据库
try {
statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象
int count = statement.executeUpdate(sql); // 执行插入操作的sql语句
conn.close(); // 关闭数据库连接
return count;// 返回插入数据的个数
} catch (SQLException e) {
e.printStackTrace();
throw new Exception("插入数据失败");
}
} /**
* 更新符合要求的记录 返回更新的记录数目
*
* @param sql
* 更新数据的sql语句
* @return count 更新数据的个数
* @throws Exception
*/
public int update(String sql) throws Exception {
conn = getConnection(); // 连接到数据库
try {
// 创建用于执行静态sql语句的Statement对象,
statement = (Statement) conn.createStatement();
int count = statement.executeUpdate(sql);// 执行更新操作的sql语句,
conn.close(); // 关闭数据库连接
return count; // 返回更新数据的个数
} catch (SQLException e) {
e.printStackTrace();
throw new Exception("更新数据失败");
}
} /**
* 查询数据库,返回符合要求的记录的数据
*
* @param sql 查询数据的sql语句
* @throws Exception
* @return list
*/
public List<Object> query(String sql) throws Exception { conn = getConnection(); // 连接到数据库
try {
statement = (Statement) conn.createStatement(); // 创建用于执行静态sql语句的Statement对象
ResultSet rs = statement.executeQuery(sql); // 执行sql查询语句,返回查询数据的结果集
List<Object> list=ResultSetToList(rs);
conn.close(); // 关闭数据库连接
return list; } catch (SQLException e) {
e.printStackTrace();
throw new Exception("查询数据失败");
}
}
/* 删除符合要求的记录,输出情况*/
/**
*
* @param sql 删除数据的sql语句
* @return count 返回删除数据的数量
* @throws Exception
*/
public int delete(String sql) throws Exception {
conn = getConnection(); //连接到数据库
try {
statement = (Statement) conn.createStatement(); //创建用于执行静态sql语句的Statement对象
int count = statement.executeUpdate(sql);// 执行sql删除语句
conn.close(); //关闭数据库连接
return count;//返回删除数据的数量
} catch (SQLException e) {
e.printStackTrace();
throw new Exception("删除数据失败");
} }
/**
* 分页查找
* @param sql 要查找的sql语句
* @param page 页数
* @param count 数据条数
* @return List<Object>
* @throws Exception
*/
public List<Object> findByPage(String sql,
int page,int count) throws Exception {
conn = getConnection(); //连接到数据库
PreparedStatement pre = conn.prepareStatement(sql);
pre.setMaxRows(count);
ResultSet rs = pre.executeQuery();
if(page<1){
rs.absolute(0);
}else{
page=page*count-1;
rs.absolute(page);
}
List<Object> list=ResultSetToList(rs);
return list;
}
/**
* ResultSet 转换成List
*/
public List<Object> ResultSetToList(ResultSet rs) throws SQLException{
if (rs == null)
return Collections.emptyList();
ResultSetMetaData md = rs.getMetaData(); // 得到结果集(rs)的结构信息
int columnCount = md.getColumnCount(); // 返回此 ResultSet 对象中的列数
List<Object> list = new ArrayList<Object>();
Map<Object, Object> rowData = new HashMap<Object, Object>();
while (rs.next()) {
rowData = new HashMap<Object, Object>(columnCount);
for (int i = 1; i <= columnCount; i++) {
rowData.put(md.getColumnName(i), rs.getObject(i));
}
list.add(rowData);
}
return list;
} }

最新文章

  1. jQuery知识点二 实现隔行变色
  2. 浮点数 (IEEE-754)
  3. ajax设置自定义请求头信息
  4. Java核心技术点之反射
  5. Expectation maximization - EM算法学习总结
  6. JAVA的instanceOf什么时候用啊
  7. HDU 3697 Selecting courses(贪心)
  8. UI设计——最后一根稻草
  9. Linux篇---ftp服务器的搭建
  10. CentOS 7 中 Systemd详解
  11. el-input的color修改无效问题
  12. Spring.Net 简单实例-02(属性注入)
  13. Android 网络编程之最新OKHTTP:3.9.0
  14. opencv的移植
  15. Python PEP 8 编码规范中文版
  16. 如何解决“504 Gateway Time-out”错误
  17. 注释和取消注释 程序中的log日志
  18. linux安装redis及phpredis环境配置
  19. POJ 3675 Telescope(简单多边形和圆的面积交)
  20. linux启动过程——(三)

热门文章

  1. DMOZ介绍以及如何提交
  2. emWin(ucGui)数值显示例程 -【worldsing笔记】
  3. Scriptcase优惠活动即将结束
  4. 51Nod 1201 整数划分 (经典dp)
  5. Codeforces Round #292 (Div. 1) B. Drazil and Tiles (类似拓扑)
  6. VSTO安装部署(完美解决XP+2007)
  7. xib上拖拽scrollview的自动布局方法
  8. ANSI_NULLS 和 QUOTED_IDENTIFIER
  9. 线程池:ThreadPoolExecutor
  10. Jquery基础:append、prepend、after、before、appendTo的区别