package cbl.dbbeans;
import java.sql.*;public class Dbmysql{

private String url="jdbc:mysql://localhost/";
private String url1="?useUnicode=true&characterEncoding=GB2312";
private String dbname="";
private String user="";
private String password="";
private Connection conn = null;
private Statement  stmt = null;
private PreparedStatement prepstmt= null;


public Dbmysql(){
}

public Dbmysql(String dbname,String user,String password){
this.dbname=dbname;
this.user=user;
this.password=password;
url=url+this.dbname+url1;

try{//获得连接
Class.forName("org.gjt.mm.mysql.Driver");
this.conn=DriverManager.getConnection(url,user,password);
}catch(Exception e)
{System.out.println("数据库连接失败");
}
}


public void init(String dbname,String user,String password){
this.dbname=dbname;
this.user=user;
this.password=password;
url=url+this.dbname+url1;
//System.out.println(this.dbname+this.user+this.password);
try
{//获得连接
Class.forName("org.gjt.mm.mysql.Driver");
}catch(Exception e)
{ //e.printStackTrace();
System.out.println("驱动加载失败");
}
try{
this.conn=DriverManager.getConnection(this.url,this.user,this.password);
//System.out.println("数据库连接成功");
}catch(Exception e)
{
System.out.println("数据库连接失败");
}
}


public ResultSet excutequery(String strsql)throws SQLException
{
//返回执行select语句的结果集
if(conn!=null){
this.stmt=conn.createStatement();
ResultSet rs=stmt.executeQuery(strsql);
return rs;
}else{
//e.printStackTrace();
System.out.println("conn="+conn.toString());
System.out.println("查询失败!");
return null;
}
} public ResultSet excutequery() throws SQLException{
if(prepstmt!=null){
ResultSet rs=prepstmt.executeQuery();
return rs;
}else return null;
}

public int excuteUpdate(String strsql)//throws SQLException
{
try{/*返回执行update,insert,delete,create,drop语句的结果
*成功:放回该语句影响的记录数?
*失败:返回0表示对数据库没有照成影响
**/
stmt=conn.createStatement();
int rs=stmt.executeUpdate(strsql);
return rs;
}catch(Exception e){
System.out.println("执行失败!");
return -1;
}

} public void excuteUpdate()throws SQLException{
if(prepstmt!=null)
prepstmt.executeUpdate();
}

/**
 * PreparedStatement
 * @return sql 预设SQL语句
 */
public void prepareStatement(String sql) throws SQLException 
{
prepstmt = conn.prepareStatement(sql);
} public void prepareStatement(String sql, int resultSetType, int resultSetConcurrency)
            throws SQLException {
prepstmt = conn.prepareStatement(sql, resultSetType, resultSetConcurrency);
}

public void clearParameters()throws SQLException{
prepstmt.clearParameters();

}

public PreparedStatement getpreStatement(){
return prepstmt;
}

public Statement getStatement(){
return stmt;
}

public Connection getConnection(){

return conn;
} public void close()throws SQLException{
if(stmt!=null) stmt.close();
if(conn!=null) conn.close();


} /**
 * 设置对应值
     *
 * @param index 参数索引
 * @param value 对应值
 */
public void setString(int index,String value) throws SQLException {
prepstmt.setString(index, value);
}
public void setInt(int index,int value) throws SQLException {
prepstmt.setInt(index,value);
}
public void setBoolean(int index,boolean value) throws SQLException {
prepstmt.setBoolean(index,value);
}
public void setDate(int index,Date value) throws SQLException {
prepstmt.setDate(index,value);
}
public void setLong(int index,long value) throws SQLException {
prepstmt.setLong(index,value);
}
public void setFloat(int index,float value) throws SQLException {
prepstmt.setFloat(index,value);
}
public void setBytes(int index,byte[] value) throws SQLException{
prepstmt.setBytes(index,value);
}
 
/**
 *设置本类参数
 *
 *
 *
 */


public void setdbname(String dbname){
this.dbname=dbname;
this.url+=this.dbname;
}


public String getdbname(){
return this.dbname;
}
public void setuser(String user){
this.user=user;
}

public String getuser(){
return this.user;
}


public void setpassword(String password){
this.password=password;
}
public String getpassword(){
return password;
}

} 这是我开发的java访问mysql数据库的类,完全可用,java访问数据库通过jdbc,所有的操作都在这里了。看看学学,你就可以自己写了