测试连接数据源

  1 ////////////////////////////////////////////////////////////////////////////////////////////
  2 //
  3 //  @name TestJdbcOdbc.java
  4 //
  5 //  @discription 测试数据库连接，以及从数据库中简单读取数据
  6 //
  7 //  @author hcm
  8 //
  9 //  @date 2006-12
 10 //
 11 //  [注]：首先建立access数据库 test ，然后建立数据表 test ，写入一些测试数据，其次建立数据源test
 12 //
 13 /////////////////////////////////////////////////////////////////////////////////////////////
 14 package TestJdbcOdbc;
 15 
 16 import java.lang.String;
 17 import java.sql.*;
 18 public class TestJdbcOdbc
 19 {
 20     public Connection con;
 21     public  Statement stm;
 22     public ResultSet rs ;
 23     /** Creates a new instance of TestJdbcOdbc */
 24     public TestJdbcOdbc ()
 25     {
 26         
 27     }
 28     //建立连接
 29     public void init()
 30     {
 31           try
 32         {
 33             Class.forName ("sun.jdbc.odbc.JdbcOdbcDriver");
 34         }
 35         catch(Exception e)
 36         {
 37             System.out.println ("初始化驱动程序异常:"+e.getMessage ());
 38         }
 39         try
 40         {
 41             con = DriverManager.getConnection ("jdbc:odbc:test");
 42             /*参数一：
 43              ResultSet.TYPE_FORWARD_ONLY
 44              ResultSet.TYPE_SCROLL_INSENSITIVE 
 45              或 ResultSet.TYPE_SCROLL_SENSITIVE 
 46              */
 47             /*参数二：
 48              *   ResultSet.CONCUR_READ_ONLY 
 49              或 ResultSet.CONCUR_UPDATABLE 之一 
 50              */
 51             //生成可更新可滚动 状态集
 52             stm = con.createStatement (ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
 53         }catch(SQLException e)
 54         {
 55             System.out.println ("连接初始化发生异常："+e.toString ());
 56         }
 57         
 58     }
 59     
 60     //插入数据
 61     public void executeInsert(String s)
 62     {
 63         try
 64         {
 65             int i = stm.executeUpdate(s);
 66         }
 67         catch(SQLException sqlexception)
 68         {
 69             System.err.println("插入数据时发生异常:" + sqlexception.getMessage());
 70         }
 71     }
 72     //删除数据
 73     public void delData(String sql)
 74     {
 75          try
 76         {
 77           stm.executeUpdate(sql);
 78         }
 79         catch(SQLException e)
 80         {
 81             System.err.println("删除数据失败: " + e.getMessage());
 82         }
 83     }
 84     //查询数据
 85     public ResultSet  queryData ( String sql)
 86     {
 87       try{
 88            rs = stm.executeQuery (sql);               
 89         }
 90         catch(SQLException e)
 91         {
 92             System.out.println ("数据库连接异常："+e.getMessage ());
 93             return rs = null;
 94         }
 95         catch(Exception e)
 96         {
 97             System.out.println ("异常:"+e.getMessage ());
 98             return rs = null;
 99         }
100       return rs;
101     }
102     //执行更新
103       public int UpdateData(String s)
104     {
105         int i = 0;
106         try
107         {
108            i = stm.executeUpdate(s);
109         }
110         catch(SQLException sqlexception)
111         {
112             System.err.println("更新数据库发生异常: " + sqlexception.getMessage());
113         }
114         return i;
115     }
116     //关闭连接
117     public void close()
118     {
119         try
120         {
121             stm.close();
122             con.close();
123         }
124         catch(SQLException sqlexception)
125         {
126             System.err.println("关闭数据库异常: " + sqlexception.getMessage());
127         }
128     }
129     /**
130      * @param args the command line arguments
131      */
132     public static void main (String[] args)
133     {
134         TestJdbcOdbc exec = new TestJdbcOdbc ();
135         //建立连接
136         exec.init();
137         /**********************************************************************************/
138         //测试查询
139         String  querysql = "select * from test";
140         try
141         {
142            exec.rs = exec.queryData (querysql);
143            while((exec.rs).next ())
144             {
145                 System.out.println ("id="+exec.rs.getString ("id")+" name= "+exec.rs.getString ("name")+"  age="+exec.rs.getString ("age"));
146             }
147         }catch(SQLException e)
148         {
149             System.out.println ("遍历查询结果时异常："+e.toString ());
150         }
151         catch(Exception e)
152         {
153             System.out.println ("发生："+e.toString ()+" 异常");
154         }
155         
156         /**********************************************************************************/
157         /**********************************************************************************/
158         
159     //测试删除数据
160         String delsql = "delete * from test where id='20031'";
161         try
162         {
163             exec.delData (delsql);
164         }
165         catch(Exception e)
166         {
167             System.out.println("删除数据发生:"+e.getMessage ());
168         }
169         /**********************************************************************************/
170         /**********************************************************************************/
171     //测试插入数据
172         String insertsql = "insert into test(id,name,age) values ('20031','test111','88')";
173         try
174         {
175             exec.executeInsert (insertsql);
176         }catch(Exception e)
177         {
178             System.out.println("插入数据："+e.getMessage());
179         }
180         /**********************************************************************************/
181         /**********************************************************************************/
182         //测试更新数据
183         String  updatesql = "update test set id = '20200',name='hechangmin' where id ='2002'";
184        try
185         {
186             System.out.println(exec.UpdateData(updatesql));
187         }catch(Exception e)
188         {
189             System.out.println("更新数据发生:"+e.getMessage());
190         }
191         /**********************************************************************************/
192         //关闭连接
193         exec.close();
194     }
195     
196 }
197