针对Student表的DAO设计实例-低调大师

针对Student表的DAO设计实例

2018-02-24 638

完整代码以及junit,mysql--connector包下载地址 : https://github.com/CasterWx/MyStudentDao

表信息:

代码:

dao包----impl包----StudentDAOImpl.java

  1 package dao.impl;
  2 
  3 import dao.IStudentDAO;
  4 import domain.Student;
  5 
  6 import java.sql.*;
  7 import java.util.ArrayList;
  8 import java.util.List;
  9 
 10 public class StudentDAOImpl implements IStudentDAO {
 11     public static Connection connection = null ;
 12 
 13     public void setConnection() {
 14         try {
 15             Class.forName("com.mysql.jdbc.Driver");
 16             System.out.println("连接成功");
 17         }catch (Exception e){
 18             System.out.println("连接失败");
 19         }
 20         try{
 21             connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/JavaJDBC","root","root");
 22         }catch (Exception e){
 23         }
 24     }
 25 
 26     public void shutdownConnection(){
 27         try {
 28             if(connection!=null){
 29                 connection.close();
 30             }
 31         }catch (Exception e){
 32         }
 33     }
 34     @Override
 35     public void save(Student student) {
 36         setConnection();
 37         Statement statement = null ;
 38         try {
 39             statement = connection.createStatement();
 40             // sql语句:查询对应id
 41             String sql = "INSERT INTO t_student(id,name,age) VALUES(" + student.getId()+",'"+student.getName()+"',"+student.getAge()+")";
 42             statement.executeUpdate(sql);
 43         }catch (Exception e){
 44         }finally {
 45             try{
 46                 if (statement!=null){
 47                     statement.close();
 48                 }
 49             }catch (Exception e){
 50             }
 51         }
 52         shutdownConnection();
 53     }
 54 
 55     @Override
 56     public void delete(Student student) {
 57         Long id = student.getId() ;
 58         delete(id);
 59     }
 60 
 61     @Override
 62     public void delete(Long id) {
 63         setConnection();
 64         Statement statement = null ;
 65         try {
 66             statement = connection.createStatement();
 67             // sql语句:查询对应id
 68             String sql = "DELETE FROM t_student WHERE id="+id;
 69             statement.executeUpdate(sql);
 70         }catch (Exception e){
 71         }finally {
 72             try{
 73                 if (statement!=null){
 74                     statement.close();
 75                 }
 76             }catch (Exception e){
 77             }
 78         }
 79         shutdownConnection();
 80     }
 81 
 82     @Override
 83     public void update(Long id, Student student) {
 84         setConnection();
 85         Statement statement = null ;
 86         try {
 87             statement = connection.createStatement();
 88             // sql语句:查询对应id
 89             String sql = "UPDATE t_student SET name='"+ student.getName() +"',age="+student.getAge() +" WHERE id="+id;
 90             statement.executeUpdate(sql);
 91         }catch (Exception e){
 92         }finally {
 93             try{
 94                 if (statement!=null){
 95                     statement.close();
 96                 }
 97             }catch (Exception e){
 98             }
 99         }
100 
101         shutdownConnection();
102     }
103 
104     @Override
105     public void update(Student student) {
106         Long id = student.getId() ;
107         update(id,student);
108     }
109 
110     @Override
111     public Student get(Long id) {
112         setConnection();
113         Statement statement = null ;
114         ResultSet resultSet = null ;
115         Student student = null ;
116         try {
117             statement = connection.createStatement();
118             // sql语句:查询对应id
119             String sql = "SELECT * FROM t_student where id="+id ;
120             resultSet = statement.executeQuery(sql);
121             if(resultSet.next()){
122                 student = new Student() ;
123                 student.setId(resultSet.getLong("id"));
124                 student.setName(resultSet.getString("name"));
125                 student.setAge(resultSet.getLong("age"));
126                 return student ;
127             }
128         }catch (Exception e){
129         }finally {
130             try{
131                 if (statement!=null){
132                     statement.close();
133                 }
134             }catch (Exception e){
135             }finally {
136                 try{
137                     if(resultSet!=null){
138                         resultSet.close();
139                     }
140                 }catch (Exception e){
141                 }
142             }
143         }
144         shutdownConnection();
145         return null;
146     }
147 
148     @Override
149     public ArrayList<Student> list() {
150         ArrayList<Student> list  = new ArrayList<Student>() ;
151         setConnection();
152         Statement statement = null ;
153         ResultSet resultSet = null ;
154         Student student = null ;
155         try {
156             statement = connection.createStatement();
157             // sql语句:查询对应id
158             String sql = "SELECT * FROM t_student" ;
159             resultSet = statement.executeQuery(sql);
160 
161             while(resultSet.next()){
162                 student = new Student() ;
163                 student.setId(resultSet.getLong("id"));
164                 student.setName(resultSet.getString("name"));
165                 student.setAge(resultSet.getLong("age"));
166                 list.add(student) ;
167             }
168             return list ;
169         }catch (Exception e){
170         }finally {
171             try{
172                 if (statement!=null){
173                     statement.close();
174                 }
175             }catch (Exception e){
176             }finally {
177                 try{
178                     if(resultSet!=null){
179                         resultSet.close();
180                     }
181                 }catch (Exception e){
182                 }
183             }
184         }
185         shutdownConnection();
186         return list;
187     }
188 
189 }

dao包----IStudentDAO接口

 1 package dao;
 2 
 3 import domain.Student;
 4 
 5 import java.util.ArrayList;
 6 import java.util.List;
 7 
 8 /**
 9  *  Student对象的CRUD操作
10  * */
11 public interface IStudentDAO {
12     // ----------------------------------增--------------------------------------------
13 
14     /**
15      * 保存学生对象
16      * @param student
17      * */
18     void save(Student student);
19 
20     // ----------------------------------删--------------------------------------------
21 
22     /**
23      *  根据删除指定学生
24      *  @param student 学生对象
25      * */
26 
27     void delete(Student student) ;
28     /**
29      *  根据主键删除指定学生
30      *  @param id    学生对象主键
31      * */
32     void delete(Long id) ;
33 
34     // ----------------------------------改--------------------------------------------
35     /**
36      *  更新指定学生信息
37      *  @param id  学生对象主键
38      *  @param student  学生对象
39      * */
40     void update(Long id,Student student) ;
41     /**
42      *  根据主键删除指定学生
43      *  @param student 学生对象
44      * */
45     void update(Student student);
46 
47     // ----------------------------------查--------------------------------------------
48 
49     /**
50      *  查询指定id的学生对象
51      *  @param id  学生对象主键
52      *  @return Student if id存在,返回Student对象,否则返回null
53      */
54     Student get(Long id) ;
55     /**
56      *  查询所有学生对象
57      *  @return 所有学生对象
58      * */
59     ArrayList<Student> list() ;
60 }

domain包-----Student.java

 1 package domain;
 2 
 3 public class Student {
 4     private long id ;
 5     private String name ;
 6     private long age ;
 7     public void getString(){
 8         System.out.println("Student(id="+id+",name="+name+",age="+age+")");
 9     }
10     public void setId(long id){
11         this.id = id ;
12     }
13     public void setName(String name){
14         this.name = name ;
15     }
16     public void setAge(long age){
17         this.age = age ;
18     }
19 
20     public long getId() {
21         return id;
22     }
23 
24     public long getAge() {
25         return age;
26     }
27 
28     public String getName() {
29         return name;
30     }
31 }

test包----StudentDAOTest

 1 package test;
 2 
 3 import dao.IStudentDAO;
 4 import dao.impl.StudentDAOImpl;
 5 import domain.Student;
 6 import org.junit.Test;
 7 
 8 import java.util.ArrayList;
 9 import java.util.List;
10 
11 public class StudentDAOTest {
12     IStudentDAO iStudentDAO = new StudentDAOImpl();
13     @Test
14     public void testSave() {
15         Student student = new Student() ;
16         student.setId(164L);
17         student.setName("Wber");
18         student.setAge(100L);
19         iStudentDAO.save(student);
20     }
21     @Test
22     public void testDelete() {
23         iStudentDAO.delete(161L);
24     }
25     @Test
26     public void testUpdate() {
27         Student student = new Student() ;
28         student.setId(161L);
29         student.setName("wa");
30         student.setAge(15L);
31         iStudentDAO.update(161L,student);
32     }
33     @Test
34     public void testGet() {
35         iStudentDAO.get(162L).getString();
36     }
37     @Test
38     public void testList() {
39         ArrayList<Student> list = iStudentDAO.list() ;
40         for(int i=0;i<list.size();i++){
41             list.get(i).getString();
42         }
43     }
44 }

微信关注我们

原文链接：https://yq.aliyun.com/articles/604899

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

微信扫描二维码下载软件

1.引用qrcode.js前，去如下地址下载或学习使用 QRCode.js教程地址可参考:http://www.runoob.com/w3cnote/javascript-qrcodejs-library.html Github 地址：https://github.com/davidshimjs/qrcodejs 2.scanner.html(生成二维码) <!doctype html><html> <head> <meta charset="utf-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <meta name="description" content=""> <meta name="keywords" content=""> <meta name="author" content="webthemez">  <title>tes...

2018-02-25

564

文章转载致博客 http://blog.csdn.net/javazejian/article/details/72828483 自己稍加完善。线程安全是并发编程中的重要关注点，应该注意到的是，造成线程安全问题的主要诱因有两点，一是存在共享数据(也称临界资源)，二是存在多条线程共同操作共享数据。因此为了解决这个问题，我们可能需要这样一个方案，当存在多个线程操作共享数据时，需要保证同一时刻有且只有一个线程在操作共享数据，其他线程必须等到该线程处理完数据后再进行，这种方式有个高尚的名称叫互斥锁，即能达到互斥访问目的的锁，也就是说当一个共享数据被当前正在访问的线程加上互斥锁后，在同一个时刻，其他线程只能处于等待的状态，直到当前线程处理完毕释放该锁。在 Java 中，关键字 synchronized可以保证在同一个时刻，只有一个线程可以执行某个方法或者某个代码块(主要是对方法或者代码块中存在共享数据的操作)，同时我们还应该注意到synchronized另外一个重要的作用，synchronized可保证一个线程的变化(主要是共享数据的变化)被其他线程所看到（保证可见性，完全可以替代Volati...

2018-02-25

574

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。