database.properties
如下：url中coursesystem为将要连接的数据库名；username为该数据库设置权限时的用户名；如果设置了密码，再添一项password=你的密码
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/coursesystem
username=root
工具util层，创建properties文件的解析工具ConfigerManager.java
package util; import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
/*
* 解析配置文件，大前提是：
* 1、 你要有个配置文件
* 2、你要解析它的工具
* 过程：1.创建配置文件的输出流
* 2.用工具去解析配置文件输出流
* 3.创建利用key值获取value值的方法
*/
public class ConfigerManager {
// 创建配置文件解析工具
private static Properties param=new Properties();
static {
String configFile="database.properties";
InputStream is = ConfigerManager.class.getClassLoader().getResourceAsStream(configFile);
try {
param.load(is);
} catch (IOException e) {
e.printStackTrace();
}
}
public static String getValue(String key) {
return param.getProperty(key);
}
}
在dao层创建进行连接数据库以及其他基本操作的BaseDao.java
package dao; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException; import util.ConfigerManager;
/*
* 普适性的增删改操作，其他的增删改操作需要继承它
*/
public class BaseDao {
private static String driver=ConfigerManager.getValue("driver");
private String url=ConfigerManager.getValue("url");
private String username=ConfigerManager.getValue("username");
Connection conn = null;
PreparedStatement pds=null;
ResultSet rs=null;
int result=0;
static {
try {
Class.forName(driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
// 建立连接
public Connection getConnection() {
try {
conn=DriverManager.getConnection(url, username, null);
System.out.println("连接已建立！");
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
// 断开连接
public void closeAll(ResultSet rs,PreparedStatement pds,Connection conn) {
if(rs!=null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(pds!=null) {
try {
pds.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
// 增、删、改
public int updateData(String sql,Object[] params) {
conn = this.getConnection();
try {
pds=conn.prepareStatement(sql);
if(params!=null) {
for(int i=0;i<params.length;i++) {
pds.setObject(i+1, params[i]); //MySQL语句中下标从1开始
}
}
result=pds.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
} finally {
this.closeAll(null, pds, conn);
}
return result;
}
// 查
public ResultSet queryData(String sql,Object[] params) {
conn=this.getConnection();
try {
pds=conn.prepareStatement(sql);
if(params!=null) {
for(int i=0;i<params.length;i++) {
pds.setObject(i+1, params[i]); //MySQL语句中下标从1开始
}
}
rs=pds.executeQuery();
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
}
简单的使用Junit对以上代码进行测试
package test;
import org.junit.Test;
import dao.BaseDao;
public class DatabaseTest {
@Test
public void linkDatabase() {
BaseDao dao=new BaseDao();
dao.getConnection();
}
}