01-三层架构之查询数据库数据

一、后台操作流程

1.创建数据库

1. CREATE DATABASE wyy_music;
3. USE wyy_music;
5. DROP TABLE IF EXISTS `tb_music`;
6. CREATE TABLE `tb_music` (
7.   `music_id` INT(11) PRIMARY KEY NOT NULL AUTO_INCREMENT, -- 歌曲ID
8.   `music_name` VARCHAR(255) NOT NULL, -- 歌曲名称
9.   `music_album_name` VARCHAR(255), -- 专辑名称
10.   `music_album_picUrl` VARCHAR(255), -- 专辑图片路径
11.   `music_mp3Url` VARCHAR(255), -- 歌曲播放路径
12.   `music_artist_name` VARCHAR(255), -- 歌手名称
13.   `sheet_id` INT(11) DEFAULT NULL -- 对应的歌单ID
14. ) ENGINE=INNODB DEFAULT CHARSET=utf8;
16. INSERT INTO tb_music VALUES ('1', '光年之外', '光年之外', 'https://imgessl.kugou.com/stdmusic/20161229/20161229233400375274.jpg', 'https://webfs.tx.kugou.com/202109061310/31fb3f36e2048b2172a70e327bbfc8e3/KGTX/CLTX001/f87095bff0de7c636c3a3b8aac702d76.mp3', 'G.E.M.邓紫棋','1');
17. INSERT INTO tb_music VALUES ('2', '夜空中最亮的星', '世界', 'https://imgessl.kugou.com/stdmusic/20150719/20150719010047203836.jpg', 'https://webfs.ali.kugou.com/202109061306/1b30ae27a5749debd602507b3bf1fea6/G202/M04/1B/13/aocBAF55G0-ADd0HAD2Y88Efqbw072.mp3', '逃跑计划','1');
18. INSERT INTO tb_music VALUES ('3', '只要平凡', '只要平凡', 'https://imgessl.kugou.com/stdmusic/20180622/20180622194005815458.jpg', 'https://webfs.ali.kugou.com/202109061309/edb2e89d90e66b9d125950dba107e9eb/KGTX/CLTX001/38aead7ed546b0736791ebb25c3a3951.mp3', '张杰/张碧晨','2');

复制代码

2.在IDEA中创建maven工程并导入依赖

1. <dependencies>
2.         <dependency>
3.             <groupId>javax.servlet</groupId>
4.             <artifactId>javax.servlet-api</artifactId>
5.             <version>4.0.1</version>
6.             <scope>provided</scope>
7.         </dependency>
8.         <dependency>
9.             <groupId>mysql</groupId>
10.             <artifactId>mysql-connector-java</artifactId>
11.             <version>8.0.32</version>
12.         </dependency>
13.         <dependency>
14.             <groupId>com.alibaba</groupId>
15.             <artifactId>druid</artifactId>
16.             <version>1.2.17</version>
17.         </dependency>
18.         <dependency>
19.             <groupId>commons-dbutils</groupId>
20.             <artifactId>commons-dbutils</artifactId>
21.             <version>1.7</version>
22.         </dependency>
23.         <dependency>
24.             <groupId>com.alibaba.fastjson2</groupId>
25.             <artifactId>fastjson2</artifactId>
26.             <version>2.0.20</version>
27.         </dependency>
28.         <dependency>
29.             <groupId>org.projectlombok</groupId>
30.             <artifactId>lombok</artifactId>
31.             <version>1.18.26</version>
32.         </dependency>
33.     </dependencies>

复制代码

3.创建db.properties文件，配置数据库

1. driverClassName=com.mysql.jdbc.Driver
2. url=jdbc:mysql://localhost:3306/wyy_music
3. username=root
4. password=1234

复制代码

4.编写工具类

1. package com.slj.util;
3. import com.alibaba.druid.pool.DruidDataSource;
4. import com.alibaba.druid.pool.DruidDataSourceFactory;
6. import java.io.InputStream;
7. import java.sql.*;
8. import java.util.Objects;
9. import java.util.Properties;
12. public class JdbcUtil {
14.     //声明一个DruidDataSource对象
15.     private static DruidDataSource ds;
16.     //声明一个ThreadLocal对象 本地线程对象，线程安全，不需要加锁，提高执行效率
17.     private static final ThreadLocal<Connection> THREAD_LOCAL = new ThreadLocal<>();
19.     //静态代码块，在类加载时只执行一次，我们可以在这里初始化数据源对象
20.     //整个项目中只需要一个数据源对象就可以 数据源内部有个连接池对象，我们之后获取连接可以从连接池中获取
21.     static {
22.         try {
23.             //读取database.properties属性文件获取到输入流对象
24.             InputStream inputStream = JdbcUtil.class.getResourceAsStream("/db.properties");
25.             //创建Properties对象
26.             Properties properties = new Properties();
27.             //属性文件中的内容就读取到properties中了
28.             properties.load(inputStream);
29.             //根据properties文件创建数据源
30.             ds = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
31.         } catch (Exception e) {
32.             e.printStackTrace();
33.         }
34.     }
37.     //获取连接的方法 getConnection
38.     public static Connection getConnection() {
39.         //从THREAD_LOCAL获取连接对象
40.         Connection connection = THREAD_LOCAL.get();
41.         if (Objects.isNull(connection)) {
42.             try {
43.                 connection = ds.getConnection();
44.                 // 第一次获取到连接对象 connection 就放到THREAD_LOCAL,以后再取的时候里面就有值了
45.                 THREAD_LOCAL.set(connection);
46.             } catch (SQLException e) {
47.                 e.printStackTrace();
48.             }
49.         }
50.         return connection;
51.     }
53.     //关闭资源的方法
54.     private static void close(Connection connection) {
55.         if (Objects.nonNull(connection)) {
56.             try {
57.                 connection.close();
58.                 //关闭连接后 把THREAD_LOCAL中的对象清除掉,一定不能忘记
59.                 THREAD_LOCAL.remove();
60.             } catch (SQLException e) {
61.                 e.printStackTrace();
62.             }
63.         }
64.     }
65. }

复制代码

5.编写实体类

1. package com.slj.entity;
3. import lombok.AllArgsConstructor;
4. import lombok.Data;
5. import lombok.NoArgsConstructor;
7. /**
8. * 实体类
9. * 有了lombok依赖，直接使用注解方式
10. */
11. @Data
12. @NoArgsConstructor
13. @AllArgsConstructor
14. public class Music {
15.     private Integer musicId;
16.     private String musicName;
17.     private String musicAlbumName;
18.     private String musicAlbumPicurl;
19.     private String musicMp3url;
20.     private String musicArtistName;
21.     private String sheetId;
22. }

复制代码

6.编写持久层（dao层）

1. package com.slj.dao;
3. import com.slj.entity.Music;
5. import java.util.List;
7. public interface MusicDao {
8.     /**
9.      * 查询所有
10.      *
11.      * @return
12.      */
13.     List<Music> queryAll();
14. }

复制代码

7.编写DaoImpl

1. package com.slj.dao.impl;
3. import com.slj.dao.MusicDao;
4. import com.slj.entity.Music;
5. import com.slj.util.JdbcUtil;
6. import org.apache.commons.dbutils.QueryRunner;
7. import org.apache.commons.dbutils.handlers.BeanListHandler;
9. import java.sql.Connection;
10. import java.sql.SQLException;
11. import java.util.List;
13. public class MusicDaoImpl implements MusicDao {
14.     private QueryRunner queryRunner = new QueryRunner();
16.     /**
17.      * 查询所有信息
18.      *
19.      * @return
20.      */
21.     @Override
22.     public List<Music> queryAll() {
23.         //1.获取连接
24.         Connection connection = JdbcUtil.getConnection();
26.         //2.SQL语句
27.         String sql = "select music_id as musicId,music_name as musicName," +
28.                 "music_album_name as musicAlbumName,music_album_picUrl as musicAlbumPicurl," +
29.                 "music_mp3Url as musicMp3url,music_artist_name as musicArtistName," +
30.                 "sheet_id as sheetId from tb_music";
32.         //3.调用方法
33.         try {
34.             return queryRunner.query(connection, sql, new BeanListHandler<>(Music.class));
35.         } catch (SQLException e) {
36.             throw new RuntimeException(e);
37.         }
38.     }
39. }

复制代码

8.编写业务逻辑层（service层）

1. package com.slj.service;
3. import com.slj.entity.Music;
5. import java.util.List;
7. public interface MusicService {
8.     /**
9.      * 查询所有歌曲
10.      *
11.      * @return
12.      */
13.     List<Music> findAll();
14. }

复制代码

9.编写ServiceImpl

1. package com.slj.service.impl;
3. import com.slj.dao.MusicDao;
4. import com.slj.dao.impl.MusicDaoImpl;
5. import com.slj.entity.Music;
6. import com.slj.service.MusicService;
8. import java.util.List;
10. public class MusicServiceImpl implements MusicService {
11.     private MusicDao musicDao = new MusicDaoImpl();
13.     //调用dao层方法
14.     public List<Music> findAll() {
15.         return musicDao.queryAll();
16.     }
17. }

复制代码

10.编写页面层（Controller层）

1. package com.slj.controller;
3. import com.alibaba.fastjson2.JSON;
4. import com.slj.entity.Music;
5. import com.slj.service.MusicService;
6. import com.slj.service.impl.MusicServiceImpl;
8. import javax.servlet.ServletException;
9. import javax.servlet.annotation.WebServlet;
10. import javax.servlet.http.HttpServlet;
11. import javax.servlet.http.HttpServletRequest;
12. import javax.servlet.http.HttpServletResponse;
13. import java.io.IOException;
14. import java.util.List;
16. @WebServlet("/findAllController.do")
17. public class FindAllController extends HttpServlet {
18.     @Override
19.     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
21.         //调用service层处理核心业务逻辑
22.         MusicService musicService = new MusicServiceImpl();
23.         List<Music> all = musicService.findAll();
25.         //将Java数据转换成Json数据
26.         String jsonString = JSON.toJSONString(all);
27.         //返回给前端
28.         response.getWriter().write(jsonString);
30.     }
32.     @Override
33.     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
34.         this.doGet(request, response);
35.     }
36. }

复制代码

11.编写过滤器（处理请求响应字符乱码问题）

1. package com.slj.filter;
3. import javax.servlet.*;
4. import javax.servlet.annotation.WebFilter;
5. import java.io.IOException;
7. @WebFilter(urlPatterns = "*.do")
8. public class EncodingFilter implements Filter {
9.     @Override
10.     public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
11.         /**
12.          * 设置编码
13.          */
15.         request.setCharacterEncoding("utf-8");
16.         response.setCharacterEncoding("utf-8");
17.         response.setContentType("text/html;charset=utf-8");
18.         chain.doFilter(request, response);
19.     }
21.     @Override
22.     public void init(FilterConfig filterConfig) throws ServletException {
23.         System.out.println("init.......");
24.     }
26.     @Override
27.     public void destroy() {
28.         System.out.println("destroy.......");
29.     }
30. }

复制代码

12.查询结果（tomcat服务器）


 二、介绍一个电脑自带浏览器的插件（可以进行测试哦）


 

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！