1.连接数据库:

import java.sql.Connection;

import java.sql.DriverManager;

public class DBConnection {

static String driver = "com.mysql.jdbc.Driver";

static String url= "jdbc:mysql://localhost:3306/mydatabase01?useUnicode=true&characterEncoding=utf-8";

static String user = "root";

static String password = "123456";

public Connection conn;

static {

try {

System.out.println("驱动加载开始=====================");

Class.forName(driver);

System.out.println("驱动加载完毕==================");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}// 加载驱动程序

}

public DBConnection() {

try {

conn = (Connection) DriverManager.getConnection(url, user, password);// 连接数据库

if(!conn.isClosed())

System.out.println("Succeeded connecting to the Database!");

} catch (Exception e) {

e.printStackTrace();

}

}

public void close() {

try {

this.conn.close();

} catch (Exception e) {

e.printStackTrace();

}

}

}

2.数据库操作

import java.lang.reflect.Field;

import java.lang.reflect.InvocationTargetException;

import java.lang.reflect.Method;

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.sql.Statement;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

public class MysqlUtil {

public static void main(String[] args) {

// TODO Auto-generated method stub

String sqlstr = "INSERT INTO student (stuname,class,sex,major,mathstore,engstore,yuwenstore) VALUES('";

sqlstr += "赵公共','大四1班','2','计算机专业','50','80','100')";

String delstr = " insert into student (stuname,class,sex,major,mathstore) values ('彭小杰','初三','1','全专业',90) ";

System.out.println(add(delstr));

}

//插入操作

public static int add(String sql) {

int i=0;

DBConnection db = new DBConnection();

try {

PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

preStmt.executeUpdate();

//Statement statement = (Statement) db.conn.createStatement();

//statement.executeUpdate(sql);

preStmt.close();

db.close();//关闭连接

i = 1;

} catch (Exception e) {

e.printStackTrace();

}

return i;//返回影响的行数，1为执行成功

}

//查找操作

public static List< Map > show(String sql, String[] params){

// String sql ="select * from employee";

List< Map > listmap = new ArrayList<>();

DBConnection db = new DBConnection();

ResultSet rs = null;

System.out.println("-----------------");

System.out.println("姓名" +"\t"+ "邮箱" +"\t"+ "日期");

System.out.println("-----------------");

try {

Statement stmt = (Statement) db.conn.createStatement();

rs = (ResultSet) stmt.executeQuery(sql);//返回链表

while(rs.next()){

Map map = new HashMap();

for(int i = 0; i < params.length; i++) {

map.put(params, rs.getString(params));

}

listmap.add(map);

}

rs.close();

db.close();//关闭连接

} catch (SQLException e) {

e.printStackTrace();

}

return listmap;

}

//更新操作

public static int update( String sql ) {

int i =0;

// String sql="update employee set email=?,pwd=? where name=?";

DBConnection db = new DBConnection();

try {

PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

// preStmt.setString(1, uemail);

// preStmt.setString(2, upwd);

// preStmt.setString(3, uname);

preStmt.executeUpdate();

preStmt.close();

db.close();//关闭连接

i = 1;

} catch (SQLException e) {

e.printStackTrace();

}

return i;//返回影响的行数，1为执行成功

}

//删除操作

public static int del(String sql) {

int i=0;

// String sql="delete from employee where name=?";

DBConnection db = new DBConnection();

try {

PreparedStatement preStmt = (PreparedStatement) db.conn.prepareStatement(sql);

preStmt.executeUpdate();

preStmt.close();

db.close();//关闭连接

i = 1;

} catch (SQLException e){

e.printStackTrace();

}

return i;//返回影响的行数，1为执行成功

}

public static List query(Class> obj, String sql) throws SQLException, InstantiationException, IllegalAccessException, IllegalArgumentException, InvocationTargetException{

Statement st=null;

List list=new ArrayList<>();

DBConnection db = new DBConnection();

Statement stmt = (Statement) db.conn.createStatement();

ResultSet rs=st.executeQuery(sql);

//获取传入类中的体例

Method[] methods=obj.getMethods();

//设置一个体例的list集合，下面将体例放入其中，以便挪用

List list_m= new ArrayList<>();

//类中有许多体例，过滤一些体例，获取自己想要的体例

for(int i=0;i

//判断体例名字中是否有set这个提取

if (methods.getName().contains("set")) {

//将体例添加到list中

list_m.add(methods);

}

}

//建立字符串string集合，获取下面的字段名存入

List fieldname=new ArrayList<>();

//获取类中的属性，其属性对应数据库中的字段

Field[] f=obj.getDeclaredFields();

//循环将字段中的名字首个变大写

for (int i = 0; i < f.length; i++) {

//获取名字

String field=f.getName();

//变巨细写，存入fieldname集合

fieldname.add(upperCase(field));

}

//获取获得结果集(rs)的结构，好比字段数、字段名等。

ResultSetMetaData rsmd= rs.getMetaData();

//循环读取结果集中的数据添加到list集合中

while (rs.next()) {

//建立一个传入类对象user

Object user=obj.newInstance();

//遍历体例的集合

for (Method m : list_m) {

//遍历字段的集合

for (int i = 0; i < f.length; i++) {

//体例和字段作比较，查看体例名中是否含有这个字段名，两者匹配

if (m.getName().contains("set"+fieldname.get(i))) {

//匹配成功 ，则去获得rsmd去获取数据库中的字段名，rs.getObject，再根据获取的这个字段名去获得这个字段值

Object value=rs.getObject(rsmd.getColumnName(i+1));

//获取这个字段的类型，以便去贮存这个值的类型

Class> type=f.getType();

//是int类型的转化

if (type==int.class) {

value=new Integer(value.toString());

}

//string类型的转化

if (type==String.class) {

value=value.toString();

}

//m是user对象中的体例，设置其值

m.invoke(user, value);

}

}

}

//将的到的user对象实例添加到list集合中

list.add(user);

}

return list;

}

public static String upperCase(String str) {

//先将字符串转换为字符数组

char[] ch = str.toCharArray();

//将数组的第一个元素 即字符串首字母，进行ASCII 码前移，ASCII 中大写字母从65开始，小写字母从97开始，所以这里减去32。

if (ch[0] >= 'a' && ch[0] <= 'z') {

ch[0] = (char) (ch[0] - 32);

}

return new String(ch);

}

}