java实现mysql操作类分享java连接mysql

CodehighlightingproducedbyActiproCodeHighlighter(freeware)http://www.CodeHighlighter.com/-->importjava.sql.*;

publicclassmysql{
   publicstaticStringurl="jdbc:mysql://localhost:3306/test";//characterEncoding=GBK
   publicstaticStringusername="root";
   publicstaticStringpassword="root";
   publicstaticConnectioncon;
   publicstaticStatementstmt;
   publicstaticResultSetrs;

   publicstaticvoidmain(String[]args)throwsSQLException{
       connect();
       operation();
       stmt.close();
       con.close();
   }
   publicstaticvoidtest(){
       Stringsql_select="select*fromtablenamewhereid=1";
       Stringsql_insert="insertintotablename(col1,col2..)values("1","2"...)";
       Stringsql_update="updatetablenamesetcolname="update"whereid=1";
       //insert(sql_insert);
       //select(sql_select);
       //update(sql_update);
   }
   publicstaticvoidconnect(){
       //定位驱动
       try{
           Class.forName("com.mysql.jdbc.Driver");
           System.out.println("加载驱动成功!");
       }catch(ClassNotFoundExceptione){
           System.out.println("加载驱动失败!");
           e.printStackTrace();
       }
       //建立连接
       try{
           con=DriverManager.getConnection(url,username,password);
           stmt=con.createStatement();
           System.out.println("数据库连接成功!");
       }catch(SQLExceptione){
           System.out.println("数据库连接失败!");
       }
   }
   publicstaticvoidselect(Stringsql){
       try{
           rs=stmt.executeQuery(sql);
           ResultSetMetaDatameta_data=rs.getMetaData();//列名
           for(inti_col=1;i_col<=meta_data.getColumnCount();i_col++){
               System.out.print(meta_data.getColumnLabel(i_col)+"  ");
           }
           System.out.println();
           while(rs.next()){
               for(inti_col=1;i_col<=meta_data.getColumnCount();i_col++){
                   System.out.print(rs.getString(i_col)+" ");
               }
               System.out.println();
           }
           rs.close();
       }catch(Exceptione){
           System.out.println("数据查询失败!");
       }
   }
   publicstaticvoidinsert(Stringsql){
       try{
           stmt.clearBatch();
           stmt.addBatch(sql);
           stmt.executeBatch();
           System.out.println("数据插入成功!");
       }catch(Exceptione){
           System.out.println("数据插入失败!");
       }

   }
   publicstaticvoidupdate(Stringsql){
       try{
           stmt.executeUpdate(sql);
           System.out.println("数据更新成功!");
       }catch(Exceptione){
           System.out.println("数据更新失败!");
       }
   }
}