一,JDBC:Java数据库连接,(Java Database Connectivity,简称JDBC)是Java语言中用来规范客户端程序如何访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法。
二,简单的JDBC实例
我使用JDBC写的一个简单程序,主要是使用JDBC连接Mysql数据库,然后对数据库进行一些基本的增删改查操作。
1,设计数据表
先设计一张数据表,用户保存用户信息,建表语句如下:
CREATE TABLE `person` ( `id` int(11) NOT NULL, `name` text NOT NULL, `phone` varchar(255) CHARACTER SET latin1 DEFAULT NULL, `age` int(11) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
在person表中定义了几个字段,分别是id,name,phone,age,其中id是主键,是自增长,name表示用户名,phone是用户的手机,age是用户的年龄。
预先在数据库中插入几条数据,数据如下:
2,定义实体类
定义一个Bean,与数据库表中的各个字段对应:
public class Person { private int id; private String name; private String phone; private int age; 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 String getPhone() { return phone; } public void setPhone(String phone) { this.phone = phone; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public String toString() { return "Person [id=" + id + ", name=" + name + ", phone=" + phone + ", age=" + age + "]"; } public Person(int id, String name, String phone, int age) { super(); this.id = id; this.name = name; this.phone = phone; this.age = age; } public Person() { super(); // TODO Auto-generated constructor stub } }
3,定义数据库连接类
定义一个数据看连接类,用户获取Mysql的连接
public class DBUtil { private static String URL = "jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8"; private static String Driver = "com.mysql.jdbc.Driver"; private static String user = "root"; private static String password = ""; public static Connection connectDB() throws Exception { Class.forName(Driver); Connection conn = DriverManager.getConnection(URL, user, password); return conn; } }
Mysql的JDBC URL编写方式为:jdbc:mysql//主机名称:连接端口/数据库名称?参数=值,为了避免中文乱码要指定useUnicode和characterEncoding.因为连接的是Mysql数据库,所以程序一开始需要加载Mysql的数据库驱动,然后通过DriverManager.getConnection(String URL)方法获取数据库的连接。
4,实现数据库的增删改查
获取了数据库的连接之后,就可以操作数据库了,下面分别实现数据库的增删改查操作,定义了一个PersonDao类用于操作数据库.
1)查询
先看查询操作,在PersonDao中定义了一个queryAll()方法:
public ListqueryAll() throws Exception { Connection conn = DBUtil.connectDB(); String sql = "SELECT * FROM person"; List personList = new ArrayList (); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(sql); while (rs.next()) { Person person = new Person(); person.setId(rs.getInt("id")); person.setName(rs.getString("name")); person.setPhone(rs.getString("phone")); person.setAge(rs.getInt("age")); personList.add(person); } return personList; }
这里使用conn.createStatement()方法获取一个Statement对象,这个对象里面有很多方法可以操作数据库,使用executeQuery(sql)执行查询操作,查询结果为一个结果集ResultSet,可以通过这个结果集获取相关信息。
定义main函数:
public static void main(String[] args){ PersonDao dao = new PersonDao(); try { ListpersonList = dao.queryAll(); for (Person person : personList) { System.out.println(person); } } catch (Exception e) { e.printStackTrace(); } }
执行结果:
Person [id=10, name=胡春, phone=18229096647, age=34] Person [id=11, name=王菲, phone=18229096640, age=21] Person [id=12, name=刘明, phone=18229096649, age=22] Person [id=13, name=白云, phone=18229096646, age=25] Person [id=15, name=黄土, phone=18229096644, age=20]
根据条件查询,定义一个queryByParams方法:
public ListqueryParams(List<> > params) throws Exception { Connection conn = DBUtil.connectDB(); String sql = "SELECT * FROM person WHERE 26=26"; System.out.println(sql.toString()); List personList = new ArrayList (); Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(sql.toString()); while (rs.next()) { Person person = new Person(); person.setId(rs.getInt("id")); person.setName(rs.getString("name")); person.setPhone(rs.getString("phone")); person.setAge(rs.getInt("age")); personList.add(person); } return personList; }
这个方法自由选择查询的条件,只需要向方法中传入一个条件List即可,这些条件都市有Map组成,每一个Map包含三个元素,col表示查询列,rel表示查询条件的关系,value是指查询条件的值。
PersonDao dao = new PersonDao(); List<>> params = new ArrayList<> >(); Map param1 = new HashMap (); param1.put("id", "20"); param1.put("name", "jaerk"); param1.put("phone", "13266512345"); param1.put("age", "%26%"); params.add(param1); Map param2 = new HashMap (); param2.put("id", "290"); param2.put("name", "jark"); param2.put("phone", "13666512345"); param2.put("age", 26); params.add(param2); try { List personList = dao.queryParams(params); for (Person person : personList) { System.out.println(person); } } catch (Exception e) { e.printStackTrace(); } }
2增加
现在在PersonDao中写一个addPerson方法用于新增一条信息:
public void addPerson(Person person) throws Exception { Connection conn = DBUtil.connectDB(); String sql = "INSERT INTO person(id, name, phone, age)" + " VALUES(?, ?, ?, ?)"; PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, person.getId()); psmt.setString(2, person.getName()); psmt.setString(3, person.getPhone()); psmt.setInt(4, person.getAge()); psmt.execute(); conn.close(); }
这个方法使用conn.prepareStatement(sql)获取一个PreparedStatement对象,使用这个方法可以传入带参数的SQL语句,而参数的值可以通过PreparedStatement.setXXX(index,value)方法指定,其中xxx为各种不同的类型,index指定第几个参数,value指定了带参数的值,便可以执行excute()方法执行sql语句了。
PersonDao dao = new PersonDao(); Person person = new Person(); person.setName("黑风"); person.setPhone("18229096642"); person.setAge(20); person.setId(16); try { dao.addPerson(person); } catch (Exception e) { e.printStackTrace(); } }
执行后再查看数据库,发现”黑风”用户插入成功
3:删除
接下来写一个删除的方法,根据用户的id来删除数据:
public void deleteUser(int id) throws Exception { Connection conn = DBUtil.connectDB(); String sql = "DELETE FROM person WHERE id = ?"; PreparedStatement psmt = conn.prepareStatement(sql); psmt.setInt(1, id); psmt.execute(); }
然后写一个main方法来验证:
PersonDao dao = new PersonDao(); try { dao.deleteUser(26); } catch (Exception e) { e.printStackTrace(); }
删除id为26的用户,运行后查看数据库:
4:更新数据库
最后来看一下更新数据库:
public void updatePerson(Person person) throws Exception { Connection conn = DBUtil.connectDB(); String sql = "UPDATE person SET name=?, phone=?, age=?" + " WHERE id=?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(4, person.getId()); pstmt.setString(1, person.getName()); pstmt.setString(2, person.getPhone()); pstmt.setInt(3, person.getAge()); pstmt.executeUpdate(); conn.close(); }
从SQL语句中可以看出更新的也就是根据用户id进行选择性的更新。
写一个main方法验证:
PersonDao dao = new PersonDao(); Person person = new Person(); person.setName("黑风"); person.setPhone("18229096642"); person.setAge(26); person.setId(18); try { dao.updatePerson(person); } catch (Exception e) { e.printStackTrace(); } }
这个方法里将用户名为黑风的用户年龄改为26岁,执行程序,运行后查看数据库:
可以看到用户的年龄变成了26,更新成功。
三,总结
使用JDBC连接Mysql数据库并进行基本的增删改查就已经完成了,这些只是最简单的数据库操作,实际开发过程中操作数据库比这些复杂多了,包括事务处理,存储过程等等,就需要使用JDBC更高级的功能了。