查看: 1044|回复: 0

[Mysql数据库] 【Java框架型项目从入门到装逼】第九节 - 数据库建表和CRUD操作

发表于 2018-2-28 08:04:37
1、新建学生表

这节课我们来把和数据库以及jdbc相关的内容完成,首先,进行数据库建表。数据库呢,我们采用mysql数据库,我们可以通过navcat之类的管理工具来轻松建表。

首先,我们得建一个数据库,名字叫db_student。然后,开始建表:

表名为t_student,保存。

学生表建好之后,我们开始测试具体的增删改查操作。

2、自定义jdbc框架 simple-jdbc

如图所示,simple-jdbc是我自己编写的一个jdbc框架,有点类似于spring-jdbc,采用DBCP数据源。目录结构如图所示,我已经把它打成了一个jar包,只需要在项目中引入即可。接下来,我们需要配置一下数据库的链接信息。

我们新建一个源文件夹etc,里面写一个配置文件,名字叫dbcpconfig.properties.注意哦,一定是叫这个名字,因为我在simple-jdbc框架中就设置了默认去读取这个文件。

  1. #连接设置
  2. driverClassName=com.mysql.jdbc.Driver
  3. url=jdbc:mysql://127.0.0.1:3306/db_student
  4. username=root
  5. password=123
  6. #<!-- 初始化连接 -->
  7. initialSize=100
  8. #最大连接数量
  9. maxActive=50
  10. #<!-- 最大空闲连接 -->
  11. maxIdle=200
  12. #<!-- 最小空闲连接 -->
  13. minIdle=5
  14. #<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
  15. maxWait=60000
  16. #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;]
  17. #注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
  18. connectionProperties=useUnicode=true;characterEncoding=UTF8
  19. #指定由连接池所创建的连接的自动提交(auto-commit)状态。
  20. defaultAutoCommit=true
  21. #driver default 指定由连接池所创建的连接的只读(read-only)状态。
  22. #如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
  23. defaultReadOnly=
  24. #driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
  25. #可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
  26. defaultTransactionIsolation=READ_UNCOMMITTED
复制代码

对应的源码:

  1. static {
  2. try {
  3. InputStream e = DBCP_source.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
  4. Properties prop = new Properties();
  5. prop.load(e);
  6. ds = BasicDataSourceFactory.createDataSource(prop);
  7. } catch (Exception arg1) {
  8. throw new ExceptionInInitializerError(arg1);
  9. }
  10. }
复制代码
3、新增用户

现在我们来测试新增用户的操作,建一个测试类:

因为我们使用了simple-jdbc,所以我们可以直接调用里面的save方法进行保存而不需要进行繁琐的jdbc操作。

在simple-jdbc中,有一个save方法,支持你传入一个map,然后把对应的数据保存到某个数据库的某一张表中。(MySQL)

案例:

  1. public class TestAdd {
  2. public static void main(String[] args) {
  3. Map map = new HashMap();
  4. map.put("id", "2018012101"); //学号
  5. map.put("username", "zsf"); //账号
  6. map.put("password", "123"); //密码
  7. map.put("name", "张三丰"); //姓名
  8. map.put("sex", "男"); //性别
  9. SimpleDao dao = new SimpleDao();
  10. dao.save("db_student", "t_student", map);
  11. System.out.println("保存成功!");
  12. }
  13. }
复制代码

让我们看一下这个方法:

  1. dao.save("db_student", "t_student", map);
复制代码

第一个参数是数据库名称,第二个参数是表名,第三个参数是载有数据的map。通过这个方法,我们不需要任何繁琐的jdbc语句,就能实现数据新增的操作!是不是很方便?

效果:

如果我们再次运行代码,就会报错:

  1. com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '2018012101' for key 'PRIMARY'
复制代码

因为id是主键,所以插入的时候是不允许重复的。

让我们多换几个数据测试一下,加几条数据:

3、删除用户

simple-jdbc没有直接删除数据的方法,但是支持用类似spring-jdbc的方式执行sql语句。比如:

  1. public class TestDelete {
  2. public static void main(String[] args) {
  3. SimpleDao dao = new SimpleDao();
  4. dao.update("delete from t_student where id = ?", 2018012102);
  5. System.out.println("删除成功!");
  6. }
  7. }
复制代码

效果:

4、修改用户

修改数据,simple-jdbc提供了非常好用的方法,先来看一个具体例子:

  1. public class TestModify {
  2. public static void main(String[] args) {
  3. Map map = new HashMap();
  4. map.put("id", "2018012103"); //学号
  5. map.put("username", "gj"); //账号
  6. map.put("password", "123456"); //密码
  7. map.put("name", "郭靖"); //姓名
  8. map.put("sex", "男"); //性别
  9. SimpleDao dao = new SimpleDao();
  10. dao.update("db_student", "t_student", map, "id");
  11. System.out.println("修改成功!");
  12. }
  13. }
复制代码

如代码所示,比如我要修改郭靖的数据,将其密码改为123456,就调用update方法。第一个参数是数据库名称,第二个参数是表名,第三个参数是载有数据的map,也就是修改后的数据。最后一个参数是主键,也就是说,根据什么字段信息来找到要修改的那一条数据?我们要修改郭靖的数据,id是一样的,都是2018012103,所以主键字段就是id,我们第四个参数就传一个“id”进去。

不需要任何繁琐的jdbc语句,你只需要一个map,搞定一切!

5、查询用户

查询用户我提供了多个接口:
1、queryForJsonObject
2、queryForJsonArray
3、queryForList
4、queryForMap
5、queryForBean
6、queryForString
7、queryForInt
8、queryForLong
9、queryForPage (分页数据)

每个方法看名字就知道是干什么用的了,这里我们就看一下其中最难的分页查询。分页查询在jdbc操作中一向是个难点,但是如果你使用我这个simple-jdbc框架,就是一句话的事情了。

例子:

  1. public class TestQueryForPage {
  2. public static void main(String[] args) {
  3. String sql = "select * from t_student where 1=1 and sex = ?";
  4. SimpleDao dao = new SimpleDao();
  5. Map<String, Object> list = dao.queryForPage(sql, 1, 10, "男");
  6. System.out.println(list);
  7. }
  8. }
复制代码

如代码所示,我要查询出学生表中所有的男同胞,就用queryForPage方法,第一个参数是查询的sql语句,第二个参数是第几页,第三个参数是每页多少行,之后是一个变长数组,对应sql语句中的 ?

效果:

  1. {
  2. total=2,
  3. rows=[{"id":2018012101,"sex":"男","username":"zsf","name":"张三丰","password":"123"},
  4. {"id":2018012103,"sex":"男","username":"gj","name":"郭靖","password":"123456"}]
  5. }
复制代码

分页的结果集就是具体的列表加上总条数,于是乎,这样就实现了。

我要下载源码



回复

使用道具 举报