JDBC链接Mysql方法_MySQL, Oracle及数据库讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方-国内领先的云技术服务提供商
»  游客             当前位置:  论坛首页 »  自由讨论区 »  MySQL, Oracle及数据库讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 1837 | 回复: 0   主题: JDBC链接Mysql方法        下一篇 
nini
注册用户
等级:新兵
经验:56
发帖:63
精华:0
注册:2011-12-16
状态:离线
发送短消息息给nini 加好友    发送短消息息给nini 发消息
发表于: IP:您无权察看 2015-7-17 9:20:34 | [全部帖] [楼主帖] 楼主

import java.sql.*;

import java.util.*;

public final class Mysql{

    private Connection conn = null;

    // private Statement st = null;

    ArrayList res = new ArrayList();

    private PreparedStatement ps = null;

    private ResultSet rs = null;

    private String url = "jdbc:mysql://localhost:3306/test";

    private String user = "root";

    private String passwd = "";

    private static final String name = "com.mysql.jdbc.Driver";

    // private String driver = "org.gjt.mm.mysql.Driver";

    static {

    try{

    // com.mysql.jdbc.Driver d = new com.mysql.jdbc.Driver();

    Class.forName(name);

    // DriverManager.registerDriver(new com.mysql.jdbc.Driver());

    }catch(ClassNotFoundException cnfe){

    cnfe.printStackTrace();

    }

    }

    public Connection getConn(){

    try{

    conn = DriverManager.getConnection(url,user,passwd);

    }catch(SQLException sqle){

    conn = null;

    sqle.printStackTrace();

    }finally{

    return conn;

}

}

public ArrayList getRs(String sql){

    try{

    // st = conn.createStatement();

    conn = getConn();

    ps = conn.prepareStatement(sql);

    rs = ps.executeQuery();

    System.out.println(conn);

    if(rs != null){

    while(rs.next()){

    ArrayList record = new ArrayList();

    record.add(rs.getInt("id"));

    record.add(rs.getString("name"));

    record.add(rs.getString("sex"));

    record.add(rs.getString("hobby"));

    res.add(record);

    }

    }

    }catch(SQLException sqle){

    sqle.printStackTrace();

}finally{

try{

if(rs != null){

    rs.close();

}

}catch(SQLException sqle){

sqle.printStackTrace();

}

return res;

}

}

public ArrayList getRs(ArrayList al, int id){

    ArrayList tmp = null;

    for(int i=0; i<al.size(); i++){

    if(id == ((ArrayList)al.get(i)).get(0)){

    tmp = (ArrayList)al.get(i);

    }

    }

    return tmp;

}

public void closeAll(){

    try{

    if(rs != null){

    rs.close();

    }

    }catch(SQLException sqle){

    sqle.printStackTrace();

}finally{

try{

if(ps != null){

    ps.close();

}

}catch(SQLException sqle){

sqle.printStackTrace();

}finally{

    try{

    if(conn != null){

    conn.close();

    }

    }catch(SQLException sqle){

    sqle.printStackTrace();

}

}

}

}

public void showRs(ArrayList al){

    if(al != null){

    for(int i=0; i<al.size(); i++){

    System.out.print(((ArrayList)al.get(i)).get(0) + " ");

    System.out.print(((ArrayList)al.get(i)).get(1) + " ");

    System.out.print(((ArrayList)al.get(i)).get(2) + " ");

    System.out.print(((ArrayList)al.get(i)).get(3) + " ");

    System.out.println(" ");

    }

    }

}

}

import java.sql.*;

import java.util.*;

public class Test{

    public static void main(String[] args){

    Mysql m = new Mysql();

    // m.init();

    String sql = "SELECT * FROM stu";

    ArrayList rs = m.getRs(sql);

    if(rs != null){

    System.out.println(rs.size());

    for(int i=0; i<rs.size(); i++){

    System.out.print(((ArrayList)rs.get(i)).get(0) + " ");

    System.out.print(((ArrayList)rs.get(i)).get(1) + " ");

    System.out.print(((ArrayList)rs.get(i)).get(2) + " ");

    System.out.print(((ArrayList)rs.get(i)).get(3) + " ");

    System.out.println(" ");

    }

    }

    ArrayList a = m.getRs(rs,3);

    if(a != null){

    for(int j=0 ;j<4; j++){

    System.out.println(a.get(j)+" ");

    }

    }

    m.closeAll();

    }

}

--转自北京联动北方科技有限公司




赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码: 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论