首先引入MySQL-connector-Java-5.0.8-wx DMT.jar
1、创建配置文件jdbc.properties
JDBC.driver=com.MySQL.JDBC.driver
JDBC.URL=JDBC : MySQL ://localhost :3306/shop
jdbc.username=root
jdbc.password=123456
2、读取配置文件类
package com.hx.shopping.util；
import java.io.IOException；
import java.util.Properties；
公共类专业实用程序{
privatestaticpropertiesprop=null；
publicstaticpropertiesgetprop{
if (prop==空值) {
prop=new Properties (；
try {
//prop util.class.getclass loader ()获取src根路径
prop.load (prop util.class.getclass loader ().getresourceasstream ) ) filename；
}catch(ioexceptione ) {
e .打印任务跟踪(；
}
}
return prop；
}
}
3、连接到MySQL类
package com.hx.shopping.util；
import Java.SQL.callable statement；
import java.sql.Connection；
import java.sql.DriverManager；
import java.sql.ResultSet；
import java.sql.SQLException；
import java.util.Properties；
公共类db util {
staticpropertiesprop=prop util.get prop (JDBC.properties )； //只写等号的后半部分就认不出来了
/*
*负载驱动
*/
publicstaticfinalstringdriver=prop.getproperty (' JDBC.driver ' )；
/*
*用于连接到数据库的URL。 端口号不是数据库端口号： 3306，8080
*/
publicstaticfinalstringurl=prop.getproperty (' JDBC.URL )；
/*
*用户名
*/
publicstaticfinalstringusername=prop.getproperty (' JDBC.username )；
/*
*密码
*/
publicstaticfinalstringpassword=prop.getproperty (JDBC.password )；
/*
*使用静态代码块加载驱动程序
*/
静态{
try {
class.forname(driver；
System.out.println (加载驱动成功！ ' )；
}catch(classnotfoundexceptione ) )
e .打印任务跟踪(；
throw new RuntimeException ('加载驱动失败！' )；
}
}
/*
*数据连接方法
*/
公共静态连接getconn (
connection conn=空；
try {
conn=driver manager.getconnection (URL，username，password )；
System.out.println (数据库连接成功！ ' )；
}catch(sqlexceptione ) {
e .打印任务跟踪(；
throw new RuntimeException ('数据库连接失败！' )；
}
return conn；
}
/*
*关闭数据库连接
*/
publicstaticvoidclose (connection conn，CallableStatement cs，ResultSet rs ) {
try {
if(RS )！=null ) {
rs.close (；
}
if(cs！=null ) {
cs.close (；
}
if(Conn！=null ) {
conn.close (；
}
}catch(sqlexceptione ) {
e .打印任务跟踪(；
}
}
/*
实现追加删除
*/
publicstaticintchangedata (object [ ] params，String sql ) )。
connection conn=空；
可调用语句cs=null；
conn=getConn (；
int num=-1；
try {
cs=Conn.preparecall(SQL；
for(intI=0； iparams.length； I ) {
cs.setobject((I1 )，params[i] )；
}
num=cs.executeUpdate (；
}catch(sqlexceptione ) {
e .打印任务跟踪(；
} finally {
try {
if(cs！=null ) {
cs.close (；
}
if(Conn！=null ) {
conn.close (；
}
}catch(sqlexceptione ) {
e .打印任务跟踪(；
}
}
return num；
}
}