我写了个jdbc连接类,如下:
public class MySqlConn {
public Connection conn = null;
public Statement stmt = null;
public ResultSet rs = null;
public PreparedStatement pstmt=null; public MySqlConn(){
try{
Class.forName("org.gjt.mm.mysql.Driver");
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/invertedindex?autoReconnect=true","root","sa");
stmt=conn.createStatement();
}
catch(Exception e){
e.printStackTrace();
}
}
public ResultSet executeQuery(String sql) throws Exception {
rs = stmt.executeQuery(sql);
return rs;
}
public void closeResultSet(){
if(this.rs!=null){
try{
this.rs.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
public void closePreparedStatement(){
if(pstmt!=null){
try{
pstmt.close();
}
catch(SQLException e){
e.printStackTrace();
}
}
}
public void closeStatement(){
if(stmt!=null){
try{
stmt.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
public void closeConn(){
if(conn!=null){
try{
conn.close();
}
catch(SQLException e){
e.printStackTrace();
}
}
}
在主函数里我作如下操作:
public static void main(String[] args) throws Exception {
MySqlConn mysql=new MySqlConn();
String sql="select DocId from doc";
while(mysql.executeQuery(sql).next()){
System.out.println(mysql.executeQuery(sql).getInt("DocId"));
}
mysql.closeResultSet();
mysql.closeStatement();
mysql.closeConn();
if(mysql.conn!=null){
System.out.print(true);
} }
像上面那样直接while(mysql.executeQuery(sql).next())是不对的,那我应该怎样用连接类里写的那个返回结果集的方法呢?还有在做了关闭ResultSet,关闭Statement,和Conn后为什么Statement,Conn等并没有真正close掉?这个连接类到底应该怎么写?先在这里谢过
public class MySqlConn {
public Connection conn = null;
public Statement stmt = null;
public ResultSet rs = null;
public PreparedStatement pstmt=null; public MySqlConn(){
try{
Class.forName("org.gjt.mm.mysql.Driver");
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/invertedindex?autoReconnect=true","root","sa");
stmt=conn.createStatement();
}
catch(Exception e){
e.printStackTrace();
}
}
public ResultSet executeQuery(String sql) throws Exception {
rs = stmt.executeQuery(sql);
return rs;
}
public void closeResultSet(){
if(this.rs!=null){
try{
this.rs.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
public void closePreparedStatement(){
if(pstmt!=null){
try{
pstmt.close();
}
catch(SQLException e){
e.printStackTrace();
}
}
}
public void closeStatement(){
if(stmt!=null){
try{
stmt.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
public void closeConn(){
if(conn!=null){
try{
conn.close();
}
catch(SQLException e){
e.printStackTrace();
}
}
}
在主函数里我作如下操作:
public static void main(String[] args) throws Exception {
MySqlConn mysql=new MySqlConn();
String sql="select DocId from doc";
while(mysql.executeQuery(sql).next()){
System.out.println(mysql.executeQuery(sql).getInt("DocId"));
}
mysql.closeResultSet();
mysql.closeStatement();
mysql.closeConn();
if(mysql.conn!=null){
System.out.print(true);
} }
像上面那样直接while(mysql.executeQuery(sql).next())是不对的,那我应该怎样用连接类里写的那个返回结果集的方法呢?还有在做了关闭ResultSet,关闭Statement,和Conn后为什么Statement,Conn等并没有真正close掉?这个连接类到底应该怎么写?先在这里谢过
这个问题解决了,再说关闭ResultSet,关闭Statement,和Conn的那个问题吧。
还有问题的话,贴错误信息
while(rs.next())
{
System.out.println(rs.getInt("DocId"));
}rs.close();
mysql.closeStatement();
mysql.closeConn();
------------------------------------------------------------
public void closeConn(){
if(conn!=null){
try{
conn.close();
conn = null;//关闭加这句
}
catch(SQLException e){
e.printStackTrace();
}
}
}
那个方法改成
public void executeQuery(String sql) throws Exception {
this.rs = stmt.executeQuery(sql);}主类改成:
public static void main(String[] args) throws Exception {
MySqlConn mysql=new MySqlConn();
String sql="select DocId from doc";
mysql.executeQuery(sql)
while(mysql.rs.next()){
System.out.println(mysql.rs.getInt("DocId"));
}
mysql.closeResultSet();
mysql.closeStatement();
mysql.closeConn();
if(mysql.conn!=null){
System.out.print(true);
}}应该就可以了
mysql.pstmt=mysql.conn.prepareStatement(sql);
mysql.pstmt.setString(1,***);
mysql.rs=mysql.pstmt.executeQuery(sql);
while(mysql.rs.next()){
//在这里我还有其他的sql过程,问题是这个时候其实mysql.pstmt和mysql.rs已经有值了,我在做其他sql过程的时候必然要对他们重新赋值,这样就不对了,所以不知道到底怎么用这个连接类
}
mysql.pstmt.setString(1,***);
mysql.rs=mysql.pstmt.executeQuery(sql);mysql.pstmt2 =mysql.conn.Statement();while(mysql.rs.next()){
//在这里我还有其他的sql过程,问题是这个时候其实mysql.pstmt和mysql.rs已经有值了,我在做其他sql过程的时候必然要对他们重新赋值,这样就不对了,所以不知道到底怎么用这个连接类
mysql.rs2=mysql.pstmt2.executeQuery(sql);
.....
}
mysql.pstmt.setString(1,***);
mysql.rs=mysql.pstmt.executeQuery(sql); mysql.pstmt2 =mysql.conn.Statement(); while(mysql.rs.next()){
//在这里我还有其他的sql过程,问题是这个时候其实mysql.pstmt和mysql.rs已经有值了,我在做其他sql过程的时候必然要对他们重新赋值,这样就不对了,所以不知道到底怎么用这个连接类
mysql.rs2=mysql.pstmt2.executeQuery(sql);
.....
} 这里还有一个问题,一个connection能创建多少个statement?有限制没有?