import java.sql.*;public class Jdbc {
private Connection con;
private Statement ste;
private ResultSet rs;
private String driver;
private String url;
/**
* 空的构造函数
*/
public Jdbc() {
}/**
*
* @param driver
* @param url
* @param username
* @param userpwd
* @throws Exception
*/
public Jdbc(String driver, String url, String username, String userpwd)
throws Exception {
try {
Class.forName(driver);
con = DriverManager.getConnection(url, username, userpwd);
ste = con.createStatement();
} catch (Exception e) {
System.out.println("出错了");
e.printStackTrace();
}
}/**
* 设置数据库连接驱动
* @param driver
* @return
*/
public boolean setDriver(String driver) {
try {
Class.forName(driver);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}/**
* 按URL,DatabaseUserName,DatabasePassword连接数据库
* @param url
* @param userName
* @param userPWD
* @return
*/
public boolean setConnection(String url, String userName, String userPWD) {
try {
con = DriverManager.getConnection(url, userName, userPWD);
ste = con.createStatement();
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}/**
* 通过SQL语句查询数据库
* @param sql
* @return
*/
public ResultSet sendQuery(String sql)
{
try {
ste =con.createStatement(
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
rs = ste.executeQuery(sql);
return rs;
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}
/**
* 处理数据更新
* @param sql
* @return
*/
public int sendUpdate(String sql)
{
try {
return ste.executeUpdate(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return 0;
//更新出错
}
/**
* 关闭相关流操作
*/
public void close()
{
try {
rs.close();
ste.close();
con.close();
} catch (Exception e) {
//e.printStackTrace();
//System.out.println("关闭数据库出错。");
}
}
/**
* 测试数据库是否成功连接
* @param args
*/
public static void main(String[] args) {
Jdbc db = new Jdbc();
db.setDriver("sun.jdbc.odbc.JdbcOdbcDriver");
db.setConnection("jdbc:odbc:dbname", "sa", "");
ResultSet res = db.sendQuery("select top 10 * from Tname");
try {
while (res.next())
System.out.println(res.getString(2));
} catch (SQLException e) {
e.printStackTrace();
}
}
}
private Connection con;
private Statement ste;
private ResultSet rs;
private String driver;
private String url;
/**
* 空的构造函数
*/
public Jdbc() {
}/**
*
* @param driver
* @param url
* @param username
* @param userpwd
* @throws Exception
*/
public Jdbc(String driver, String url, String username, String userpwd)
throws Exception {
try {
Class.forName(driver);
con = DriverManager.getConnection(url, username, userpwd);
ste = con.createStatement();
} catch (Exception e) {
System.out.println("出错了");
e.printStackTrace();
}
}/**
* 设置数据库连接驱动
* @param driver
* @return
*/
public boolean setDriver(String driver) {
try {
Class.forName(driver);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}/**
* 按URL,DatabaseUserName,DatabasePassword连接数据库
* @param url
* @param userName
* @param userPWD
* @return
*/
public boolean setConnection(String url, String userName, String userPWD) {
try {
con = DriverManager.getConnection(url, userName, userPWD);
ste = con.createStatement();
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}/**
* 通过SQL语句查询数据库
* @param sql
* @return
*/
public ResultSet sendQuery(String sql)
{
try {
ste =con.createStatement(
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
rs = ste.executeQuery(sql);
return rs;
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}
/**
* 处理数据更新
* @param sql
* @return
*/
public int sendUpdate(String sql)
{
try {
return ste.executeUpdate(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return 0;
//更新出错
}
/**
* 关闭相关流操作
*/
public void close()
{
try {
rs.close();
ste.close();
con.close();
} catch (Exception e) {
//e.printStackTrace();
//System.out.println("关闭数据库出错。");
}
}
/**
* 测试数据库是否成功连接
* @param args
*/
public static void main(String[] args) {
Jdbc db = new Jdbc();
db.setDriver("sun.jdbc.odbc.JdbcOdbcDriver");
db.setConnection("jdbc:odbc:dbname", "sa", "");
ResultSet res = db.sendQuery("select top 10 * from Tname");
try {
while (res.next())
System.out.println(res.getString(2));
} catch (SQLException e) {
e.printStackTrace();
}
}
}
解决方案 »
- 关于java剔除手机黑名单的算法,有没有更好的?
- AJAX验证问题,急~~
- 请问:设计C/S结构的程序,使用myeclipse,那么,怎么设计界面呢?
- java连接SQLServer2000问题
- 在JAVA中如何使用C++的类,而不是调用C/C++的方法
- 在xp系统中java连sqlserver的补丁包
- 发表下感慨:(
- 请问java2中的 javax.swing.tabbedpane活动页在java1中有实现相同功能的类似的控件吗?在线等待,急!!!!!!!!
- 请教JDBC是否可以跨网段(路由器)访问数据库??
- 推荐一下哪个sdk从功能+易学性来说最优?
- 请问JDBC有没有取得新插入的记录的id的函数?
- 如何得到对象声明的地方:
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
this.connect = DriverManager.getConnection("jdbc:odbc:mydsn", "user",
"pwd");