你先写一个连接数据库的类,里面写个查询方法:
public ResultSet doQuery(String sql){
Connection con= //这个连接数据库里会有个得到连接的方法,这里可以直接调用它
Statement st=con.createStatement();//
ResultSet rs= st.execusQuery(sql);执行查询,返回一个ResultSet类型
return rs;
}
如果你要执行查询功能了,就new一个这个连接数据库的对象,然后通过对象引用调用这个查询的方法,传入一个执行查询的sql语句。然后通过接受一个ResultSet类型的返回值,再循环把值取出来就可以了
算了,给你写全吧、、
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
public class JDBC {
private Connection con = null;
private Statement stmt = null;
private ResultSet rs = null;
private String driver = "com.mysql.jdbc.Driver";
private String url="jdbc:sqlserver//localhost:xxx/xxxx";//xxx写你的数据库端口号,xxxx写数据库名字
private String user = "sa";//数据库的用户名
private String password = "password";//数据库的密码
/**
* 准备连接
*/
public void startConnection() throws ClassNotFoundException, SQLException {
Class.forName(driver); //注册数据库驱动
con = DriverManager.getConnection(url, user, password); //获得数据库连接
}
/**
* 执行select 并返回结果集 throws SQLException
*/
public ResultSet doQuery(String sql) throws SQLException {
stmt = con.createStatement(); //创建Statement
rs = stmt.executeQuery(sql); //执行查询
return rs;
}
/**
* 执行insert update delete
*/
public int update(String sql) throws SQLException {
stmt = con.createStatement();
int r = stmt.executeUpdate(sql);
return r;
}
/**
* 释放资源(连接)
*/
public void releaseConnection() {
try {
if (rs != null)
rs.close();
stmt.close();
if (con != null)
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
import java.sql.*;
public class OperateDatabase {
Connection con=null;
PreparedStatement prepare;
Statement statement;
public OperateDatabase(String datasource,String user,String pass){//构造函数
try{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
con=DriverManager.getConnection("jdbc:odbc:"+datasource, user, pass);
}catch(Exception ee){
System.out.println("data source Error:"+ee);
}
}
public int anyOperate(String sqlStr){//执行操作方法
try{
statement=con.createStatement();//建立语句对象
statement.execute(sqlStr);//执行SQL操作
return 1; //操作成功
}catch(Exception err1){
System.out.println("执行操作错误:"+err1);
return 0;//操作失败
}
}
}
————————————————————————————————————————
import java.sql.*;
public class TestQuery {
/**
* @param args
*/
public static void main(String[] args) {
//用ODBC建立的数据源为MyDataSource,sa为数据库操纵员,口令为why
OperateDatabase op1=new OperateDatabase("MyDataSource","sa","why");
ResultSet rs=op1.query("SELECT * FROM user");//执行查询语句,user为用户表
try{
while(rs.next()){
for(int i=1;i<=6;i++){
System.out.print(rs.getString(i).trim()+"\t");
}
System.out.println();
}
}catch(Exception e143){
System.out.println(e143);
}
finally{
try{
if(op1.getConn() != null){
op1.getConn().close();
}
}catch(SQLException sqle){
sqle.printStackTrace();
}
}
}
}
你参考一下吧,希望对你有所帮助。