create table student(
int id primary key auto_increment,
name varchar(30),
age int,
sex varchar(30)
);
package com.syh.jdbc;
/**
* 实体类
* @author syh
*
*/
public class Student {
//学号
private int id ;
//姓名
private String name ;
//年龄
private int age ;
//性别
private String sex ;
public Student() {}
public Student(int id, String name, int age, String sex) {
this.id = id;
this.name = name;
this.age = age;
this.sex = sex;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
@Override
public String toString() {
return "Student [id=" + id + ", name=" + name + ", age=" + age
+ ", sex=" + sex + "]";
}
}
package com.syh.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 工具类
* @author syh
*
*/
public class JdbcUtils {
public static final String DRIVER = "com.mysql.jdbc.Driver" ;
public static final String URL = "jdbc:mysql://localhost:3306/itcast" ;
public static final String USR = "root" ;
public static final String PASSWORD = "root" ;
//获取链接
public static Connection getConnection() {
Connection conn = null ;
try {
Class.forName(DRIVER) ;
conn = DriverManager.getConnection(URL, USR, PASSWORD) ;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn ;
}
// 释放资源
public static void close(ResultSet rs, Statement stmt, Connection conn) {
try {
if(null != rs) {
rs.close() ;
rs = null ;
}
if(null != stmt) {
stmt.close() ;
stmt = null ;
}
if(null != conn) {
conn.close() ;
conn = null ;
}
}catch (Exception e) {
e.printStackTrace() ;
}
}
}
package com.syh.jdbc;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import org.apache.commons.beanutils.PropertyUtils;
/**
* 数据库访问类
* @author syh
*
*/
public class JdbcDao {
/**
* 根据 sql, clazz, args 返回和数据库中记录对应的一个对象 ,这个方法不能对事务进行管理
* @param <T>: 返回的对象的泛型类型
* @param sql: JDBC 查询使用的 sql 语句
* @param clazz: 返回对象对应的类型
* @param args: 填充 sql 语句中占位符的可变参数
* @return: 一个对象
*/
//这里声明了一个泛型的方法
public static <T> T getBy(String sql, Class<T> clazz, Object ... args) {
Object obj = null ;
Connection conn = null ;
PreparedStatement pstmt = null ;
ResultSet rs = null ;
Map<String, Object> map = new HashMap<String, Object>() ;
try {
conn = JdbcUtils.getConnection() ;
pstmt = conn.prepareStatement(sql) ;
for(int i = 0 ; i < args.length ; i ++) {
pstmt.setObject(i + 1, args[i]) ;
}
//执行查询
rs = pstmt.executeQuery() ;
// 得到描述结果集的 ResultMetaData 对象
ResultSetMetaData rsmd = rs.getMetaData() ;
// 得到查询的列的数量
int columnIndex = rsmd.getColumnCount() ;
//遍历结果集, 得到每一列的值. 把这些值放在一个 Map<String, Object> 中, 键为该列的名字
//看清楚这里用的是 if 而不是 while ,因为这里仅仅返回的是一条数据,所以用 if 就可以了
if(rs.next()) {
for(int i = 0 ; i < columnIndex ; i ++) {
Object o = rs.getObject(i + 1) ;
String columnName = rsmd.getColumnName(i + 1) ;
//这里一定要想清楚往 Map 对象中放的是甚么!
map.put(columnName, o) ;
}
}
// 创建 clazz 对应类的对象 obj
obj = clazz.newInstance() ;
// 为 obj 对应的属性赋值
for(Map.Entry<String, Object> entry : map.entrySet()) {
String attrName = entry.getKey() ;
Object attrValue = entry.getValue();
//方法1:通过调用工具类的方法, 调用 setter 方法为属性赋值——这里要引入 jar 包,下面提供下载
// PropertyUtils.setProperty(obj, attrName, attrValue) ;
//方法2 :直接通过反射为属性(非 Java Bean 意义)赋值
//获取属性名
// Field field = clazz.getDeclaredField(attrName) ;
// //抑制Java对起属性的检查
// field.setAccessible(true) ;
// field.set(obj, attrValue) ;
//方法3:通过反射调用 setter 方法
//1). 获取方法名,通过 拼字符串的方式
String methodName = "set" + attrName.toUpperCase().substring(0, 1)
+ attrName.substring(1) ;
//2). 获取方法的参数类型,是通过获取类的属性得到其相应的类型
Field field = clazz.getDeclaredField(attrName) ;
//抑制 Java 对属性的检查
field.setAccessible(true) ;
Class<?> type = field.getType() ;
//3). 获取方法并传入参数
Method method = clazz.getDeclaredMethod(methodName, type) ;
//4). 调用 setter 方法,将要设置的属性值 set 进去
method.invoke(obj, attrValue) ;
}
} catch (Exception e) {
e.printStackTrace();
}
return (T) obj ;
}
/**
* 这个方法的功能有——INSERT UPDATE DELETE
* @param sql: SQL 语句
* @param args: 传进来的参数
*/
public static void update(String sql, Object ... args) {
Connection conn = null ;
PreparedStatement pstmt = null ;
try {
conn = JdbcUtils.getConnection() ;
pstmt = conn.prepareStatement(sql) ;
if (null != args){
for(int i = 0 ; i < args.length ; i ++) {
pstmt.setObject(i + 1, args[i]) ;
}
}
pstmt.executeUpdate() ;
} catch (SQLException e) {
e.printStackTrace();
} finally {
JdbcUtils.close(null, pstmt, conn) ;
}
}
}
package com.syh.jdbc;
import static org.junit.Assert.*;
import org.junit.Test;
/**
* 测试类
* @author syh
*
*/
public class JdbcDaoTest {
@Test
public void testGetBy() {
//根据 id 找到相应的 Student 对象
// int id = 3 ;
// String sql = "SELECT id, name, age, sex FROM student WHERE id = ?" ;
// Student stu = JdbcDao.getBy(sql, Student.class, id) ;
// System.out.println(stu);
//根据 name 找到相应的 Student 对象
String name = "BOb";
String sql2 = "SELECT id, name, age, sex FROM student WHERE name = ?" ;
Student stu2 = JdbcDao.getBy(sql2, Student.class, name) ;
System.out.println(stu2);
}
@Test
public void testUpdate() {
// String sql = "INSERT INTO student (name, age, sex) VALUES (?, ?, ?)" ;
// JdbcDao.update(sql, "Mike", 21, "Male") ;
// String sql = "UPDATE student SET age = age + 1" ;
// JdbcDao.update(sql) ;
String sql = "DELETE FROM student WHERE id = ?" ;
JdbcDao.update(sql, 2) ;
}
}
分享到:
相关推荐
MySQL——JDBC编程
javaSwing+JDBC+Mysql项目——零食贩卖管理系统,内含增删改查等完整版操作。操作简单,部署也简单,极易学会。
同名字,mysql的连接的jdbc 在做其他软件连接mysql的时候尤其是odbc数据源的时候用得到,
mysqls是目前应用比较广泛的数据库,在 Java中使用JDBC连接。
目的:使用JDBC连接MySQL数据库并且完成增删改查。 介绍:1)一种执行SQL语言的Java API。 2)可以对所以主流数据库进行统一访问(access,MySQL,sql server,Oracle)。 3)极大地减少了程序操作数据库的复杂...
JDBC数据类型与数据库字段对应表——mysql篇 数值型 整型 JDBC tinyint java.lang.Integer smallint mediumint java.lang.Long int bigint java.math.BigInteger
mysql——JDBC连接驱动,解压将bin..jar的文件置于Javalib目录ext文件中,在创建项目时导入buildpath
用于mysql的连接,一个驱动文件jar包,用于连接mysql数据库
NULL 博文链接:https://clojure.iteye.com/blog/1741375
JDBC——属性文件的用途之一 嘎嘎!大家看看这段代码,是不是可以把1 2 3 4 放在一个文件中,这样即使换了其他的数据库也不需要改写代码,只需要改写配置文件就行了。 public static Connection getConnection(){ ...
JDBC数据类型与数据库字段对应表——mysql篇
关于jdbc的基础知识。 1:MySQL简介 2:MySQL列类型 3:SQL语句语法 4:MySQL图形界面操作
本篇文章主要介绍了JDBC处理MySQL大数据,有时是需要用程序把大文本或二进制数据直接保存到数据库中进行储存的,非常具有实用价值,需要的朋友可以参考下。
源自我自己做的一个小项目,只实现了所有ATM的功能,与后台MySQL建立连接,在控制台进行用户交互,非常适合新手练习,全部敲完后基本掌握这一块章节内容
JDBC--MySOL MySql数据库的JDBC实现增删改查————GUI实现
数据库连接jar包,mysql-connector-java-5.0.5-bin.jar——mysql,ojdbc14.jar——oracle,sqljdbc4——sql
包括 mysql-connector-java-5.1.7-bin msutil mssqlserver msbase 用于管理与数据库的连接
文章目录事务一、事务的基本介绍1、概念2、操作3、操作实例4、MySQL数据库中默认自动提交二、事务的四大特征三、事务的隔离级别1、概念2、存在的问题3、隔离级别四、Jdbc事务控制1、概述2、控制事务的API:3、核心...
* mysql:使用mysql的jdbc服务 * localhost:使用本地的mysql的jdbc服务 * 3306:使用本地的3306端口的mysql的jdbc服务 * ------- * jt_db 使用的数据库 * characterEncoding=utf-8 设置编码...
比如mysql的Java的JDBC驱动程序——mysql-connector-java-5.1.26-bin.jar。再比如.net平台的操作数据库的规范ADO。 模块2:连接池,Mysql自身有个连接池,为了连接线程的复用,Mysql将其进行了池化。将连接资源进行...