package TestJdbcOdbc;
import java.lang.String;
import java.sql.*;
public class TestJdbcOdbc
{
public Connection con;
public Statement stm;
public ResultSet rs ;
/** Creates a new instance of TestJdbcOdbc */
public TestJdbcOdbc ()
{
}
//建立连接
public void init()
{
try
{
Class.forName ("sun.jdbc.odbc.JdbcOdbcDriver");
}
catch(Exception e)
{
System.out.println ("初始化驱动程序异常:"+e.getMessage ());
}
try
{
con = DriverManager.getConnection ("jdbc:odbc:test");
/*参数一：
ResultSet.TYPE_FORWARD_ONLY
ResultSet.TYPE_SCROLL_INSENSITIVE
或 ResultSet.TYPE_SCROLL_SENSITIVE
*/
/*参数二：
* ResultSet.CONCUR_READ_ONLY
或 ResultSet.CONCUR_UPDATABLE 之一
*/
//生成可更新可滚动 状态集
stm = con.createStatement (ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
}catch(SQLException e)
{
System.out.println ("连接初始化发生异常："+e.toString ());
}
}
//插入数据
public void executeInsert(String s)
{
try
{
int i = stm.executeUpdate(s);
}
catch(SQLException sqlexception)
{
System.err.println("插入数据时发生异常:" + sqlexception.getMessage());
}
}
//删除数据
public void delData(String sql)
{
try
{
stm.executeUpdate(sql);
}
catch(SQLException e)
{
System.err.println("删除数据失败: " + e.getMessage());
}
}
//查询数据
public ResultSet queryData ( String sql)
{
try{
rs = stm.executeQuery (sql);
}
catch(SQLException e)
{
System.out.println ("数据库连接异常："+e.getMessage ());
return rs = null;
}
catch(Exception e)
{
System.out.println ("异常:"+e.getMessage ());
return rs = null;
}
return rs;
}
//执行更新
public int UpdateData(String s)
{
int i = 0;
try
{
i = stm.executeUpdate(s);
}
catch(SQLException sqlexception)
{
System.err.println("更新数据库发生异常: " + sqlexception.getMessage());
}
return i;
}
//关闭连接
public void close()
{
try
{
stm.close();
con.close();
}
catch(SQLException sqlexception)
{
System.err.println("关闭数据库异常: " + sqlexception.getMessage());
}
}
/**
* @param args the command line arguments
*/
public static void main (String[] args)
{
TestJdbcOdbc exec = new TestJdbcOdbc ();
//建立连接
exec.init();
/**********************************************************************************/
//测试查询
String querysql = "select * from test";
try
{
exec.rs = exec.queryData (querysql);
while((exec.rs).next ())
{
System.out.println ("id="+exec.rs.getString ("id")+" name= "+exec.rs.getString ("name")+" age="+exec.rs.getString ("age"));
}
}catch(SQLException e)
{
System.out.println ("遍历查询结果时异常："+e.toString ());
}
catch(Exception e)
{
System.out.println ("发生："+e.toString ()+" 异常");
}
/**********************************************************************************/
/**********************************************************************************/
//测试删除数据
String delsql = "delete * from test where id='20031'";
try
{
exec.delData (delsql);
}
catch(Exception e)
{
System.out.println("删除数据发生:"+e.getMessage ());
}
/**********************************************************************************/
/**********************************************************************************/
//测试插入数据
String insertsql = "insert into test(id,name,age) values ('20031','test111','88')";
try
{
exec.executeInsert (insertsql);
}catch(Exception e)
{
System.out.println("插入数据："+e.getMessage());
}
/**********************************************************************************/
/**********************************************************************************/
//测试更新数据
String updatesql = "update test set id = '20200',name='hechangmin' where id ='2002'";
try
{
System.out.println(exec.UpdateData(updatesql));
}catch(Exception e)
{
System.out.println("更新数据发生:"+e.getMessage());
}
/**********************************************************************************/
//关闭连接
exec.close();
}
}
