四、DataSql 数据库操作类
package edu.scnu.cn.common;
import java.sql.*;
/** *//**
*
* @author li
*
*数据库操作类
*/
public class DataSql ...{
/** *//**
*
* @return
* @throws InstantiationException
* @throws IllegalAccessException
* @throws ClassNotFoundException
*
* 直接连接到数据库,数据库指定为crjy
*/
public Connection getConn() throws InstantiationException, IllegalAccessException, ClassNotFoundException
...{
//数据库用户名
String userName="root";
//密码
String userPasswd="admin222";
//数据库名
String dbName="crjy";
//联结字符串
String url="jdbc:mysql://localhost:3306/"+dbName+"?useUnicode=true&characterEncoding=GB2312&user="+userName+"&password="+userPasswd;
Class.forName("com.mysql.jdbc.Driver").newInstance();
Connection conn=null;
try
...{
conn = DriverManager.getConnection(url);
}
catch (SQLException e)
...{
e.printStackTrace();
}
return conn;
}
/** *//**
*
* @param conn 到数据库的连接
* @param sql sql串
* @return
*
* 得到数据集
*
*/
public ResultSet getRs(Connection conn,String sql)
...{
Statement statement=null;
ResultSet rs=null;
try ...{
statement = conn.createStatement();
rs = statement.executeQuery(sql);
} catch (SQLException e) ...{
// TODO 自动生成 catch 块
e.printStackTrace();
}
return rs;
}
/** *//**
*
* @param conn 到数据库的连接
* @param sql sql串
* @return
*
* 执行删除,更新等操作
*/
public int execute(Connection conn,String sql)
...{
Statement statement=null;
int i=0;
try ...{
statement = conn.createStatement();
i= statement.executeUpdate(sql);
} catch (SQLException e) ...{
// TODO 自动生成 catch 块
e.printStackTrace();
}
return i;
}
}