java连接mysql数据库学习示例
package sns.team6.util;
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
/**
* 链接数据库的工具类
*
* @author 徐锐
*
*/
public class dbhelper {
// mysql驱动路径
private static final string driver = "com.mysql.jdbc.driver";
// 数据库的连接路径
private static final string url = "jdbc:mysql://localhost:3306/snsteam6";
/**
* 连接数据库的对象
*
* @return
*/
public static connection getconnection() {
connection conn = null;
try {
class.forname(driver);
conn = drivermanager.getconnection(url, "root", "root");
} catch (exception e) {
e.printstacktrace();
}
return conn;
}
/**
* 关闭打开的资源
*
* @param conn
* @param pst
* @param rst
*/
public static void closeinfo(connection conn, preparedstatement pst,
resultset rst) {
try {
if (rst != null) {
rst.close();
rst = null;
}
if (pst != null) {
pst.close();
pst = null;
}
if (conn != null) {
conn.close();
conn = null;
}
} catch (exception e) {
e.printstacktrace();
}
}
/**
* 获取结果集对象
*
* @param sql
* @param params
* @return
*/
public static resultset resultset(string sql, object[] params) {
// 数据库的链接对象
connection conn = null;
// 数据库的操作对象
preparedstatement pst = null;
// 结果对象
resultset rst = null;
try {
// 数据库的链接对象
conn = dbhelper.getconnection();
// 数据库的操作对象
pst = conn.preparestatement(sql);
// 判断是否有参数
if (params != null && params.length > 0) {
for (int i = 0; i < params.length; i++) {
// 给操作对象赋值
pst.setobject(i + 1, params[i]);
}
}
// 获取结果对象
rst = pst.executequery();
} catch (sqlexception e) {
rst = null;
e.printstacktrace();
}
return rst;
}
/**
* 获取添加的结果对象
*
* @param sql
* @param params
* @return
*/
public static boolean result(string sql, object[] params) {
boolean flag = false;
// 数据库的链接对象
connection conn = null;
// 数据库的操作对象
preparedstatement pst = null;
try {
// 数据库的链接对象
conn = dbhelper.getconnection();
// 数据库的操作对象
pst = conn.preparestatement(sql);
// 判断是否有参数
if (params != null && params.length > 0) {
for (int i = 0; i < params.length; i++) {
// 给操作对象赋值
pst.setobject(i + 1, params[i]);
}
}
// 获取结果对象,是int类型,表示执行成功的行数
int row = pst.executeupdate();
if (row > 0) {
// 如果大于0,表示执行成功
flag = true;
}
} catch (sqlexception e) {
flag = false;
e.printstacktrace();
}
return flag;
}
}