jdbc访问数据库

7.在src/main/java下创建接口StudentDao,包名(com.mycompany.dao),目录结构如图所示

8.接口StudentDao的内容如下

package com.mycompany.dao;
import java.util.List;
import com.mycompany.domain.Student;
/**
 * 学生DAO接口
 * @author Administrator
 *
 */
public interface StudentDao {
/**
 * 查询所有学生
 * @return 学生列表
 */
public List<Student> query();
/**
 * 添加学生
 * @param student
 */
public void save(Student student);
}

9.在src/main/java下创建接口StudentDao的实现类StudentDaoImpl,包名(com.mycompany.dao.impl),目录如图所示

10.StudentDaoImpl实现类的内容如下

package com.mycompany.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import com.mycompany.dao.StudentDao;
import com.mycompany.domain.Student;
import com.mycompany.util.JDBCUtil;
public class StudentDaoImpl implements StudentDao {
public List<Student> query() {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
List<Student> students = new ArrayList<Student>();
String sql = "select * from student";
try {
connection = JDBCUtil.getConnection();
preparedStatement = connection.prepareStatement(sql);
resultSet = preparedStatement.executeQuery();
while(resultSet.next()){
int sid = resultSet.getInt("sid");
String name = resultSet.getString("name");
Student student = new Student(sid,name);
students.add(student);
}
} catch (Exception e) {
e.printStackTrace();
} finally{
JDBCUtil.release(resultSet, preparedStatement, connection);
}
return students;
}
public void save(Student student) {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
List<Student> students = new ArrayList<Student>();
String sql = "insert into student(name) values(?)";
try {
connection = JDBCUtil.getConnection();
preparedStatement = connection.prepareStatement(sql);
preparedStatement.setString(1, student.getName());
preparedStatement.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally{
JDBCUtil.release(resultSet, preparedStatement, connection);
}
}
}

11.在src/main/resources下创建db.properties属性文件,存储数据库连接信息

12.db.properties属性文件的内容如下

jdbc.url=jdbc:mysql:///test
jdbc.user=root
jdbc.password=
jdbc.driverClass=com.mysql.jdbc.Driver

13.在src/test/java下创建测试类StudentDaoImplTest,包名(com.mycompany.dao.impl),目录结构如图所示

14.测试类StudentDaoImplTest的内容如下

package com.mycompany.dao.impl;
import java.util.List;
import org.junit.Test;
import com.mycompany.dao.StudentDao;
import com.mycompany.domain.Student;
public class StudentDaoImplTest {
@Test
public void testQuery(){
StudentDao studentDao = new StudentDaoImpl();
List<Student> students = studentDao.query();
for (Student student : students) {
System.out.println(student);
}
}
@Test
public void testSave(){
Student student = new Student("test save");
StudentDao studentDao = new StudentDaoImpl();
studentDao.save(student);
}
}

本文出自 “素颜” 博客，谢绝转载！

jdbc访问数据库

标签：jdbc访问数据库