Java、XML與數據庫編程實踐 (四)

2019-11-18 10:48:38

字體：大中小

來源：轉載

供稿：網友

　　PRotected boolean alreadyin(String tname,String colname, String value)
　　
　　　　{　　　
　　
　　　　　　int result;
　　
　　　　　　ResultSet rst=null;
　　
　　　　　　try {
　　
　　　　　　//執行SQL語句
　　
　　　　　　String query = "select "+colname+" from "+tname+" where "+colname+"='"+value+"'";
　　
　　　　　　Statement statement = connformax.createStatement();
　　
　　　　　　rst = statement.executeQuery( query );
　　
　　　　　　if(rst.next())
　　
　　　　　　{
　　
　　　　　　　　statement.close();
　　
　　　　　　　　rst.close();
　　
　　　　　　　　return true;
　　
　　　　　　}　　　
　　
　　　　 }
　　
　　　　 catch ( SQLException sqlex ) {
　　
　　　　　　sqlex.printStackTrace();
　　
　　　　　　return false;
　　
　　　　 }
　　
　　　　 return false;　　
　　
　　　　}
　　
　　　　protected int getIdfromNumber(String tname,String colname, String value)
　　
　　　　{　　　
　　
　　　　　　int result;
　　
　　　　　　ResultSet rst=null;
　　
　　　　　　try {
　　
　　　　　　Connection conn= DriverManager.getConnection( destPara.getUrl(), destPara.getUsername(),destPara.getPassWord());
　　
　　　　　　String query = "select id,"+colname+" from "+tname+" where "+colname+"='"+value+"'";
　　
　　　　　　System.out.println(query);
　　
　　　　　　Statement statement = conn.createStatement();
　　
　　　　　　rst = statement.executeQuery( query );
　　
　　　　　　if(rst.next())
　　
　　　　　　{
　　
　　　　　　　　return rst.getInt("id");
　　
　　　　　　}
　　
　　　　 }
　　
　　　　 catch ( SQLException sqlex ) {
　　
　　　　　　sqlex.printStackTrace();
　　
　　　　　　return 0;
　　
　　　　 }
　　
　　　　 return 0;　　
　　
　　　　}
　　
　　　　/**
　　
　　　　 * 得到某個表中的最大的id號
　　
　　　　 */
　　
　　　　protected int getMax(String tname)
　　
　　　　{　　　
　　
　　　　　　int result;
　　
　　　　　　ResultSet rst=null;　　
　　
　　　　　　try {
　　
　　　　　　//執行SQL語句
　　
　　　　　　String query = "select Max(id) from "+tname;
　　
　　　　　　Statement statement = connformax.createStatement();
　　
　　　　　　rst = statement.executeQuery( query );
　　
　　　　　　if(rst.next())
　　
　　　　　　{
　　
　　　　　　　　return rst.getInt(1)+1;
　　
　　　　　　}
　　
　　　　 }
　　
　　　　 catch ( SQLException sqlex ) {
　　
　　　　　　sqlex.printStackTrace();
　　
　　　　　　return 0;
　　
　　　　 }
　　
　　　　 return 1;　　
　　
　　　　}
　　
　　　　/**
　　
　　　　 * 執行某一段sql語句
　　
　　　　 */
　　
　　　　public static void execute(ConnPara connpara,String stmt) throws SQLException
　　
　　　　{
　　
　　　　　　Connection conn=null;
　　
　　　　　　PreparedStatement ps = null;
　　
　　　　　　try {
　　
　　　　　　　　conn=DriverManager.getConnection( connpara.getUrl(),　connpara.getUsername(), connpara.getPassword());
　　
　　　　　　　　System.out.println(stmt);
　　
　　　　　　　　ps = conn.prepareStatement(stmt);
　　
　　　　　　　　ps.executeUpdate();
　　
　　　　　　} catch (Exception e) {
　　
　　　　　　　　e.printStackTrace();
　　
　　　　　　　　System.out.println(e.getMessage());
　　
　　　　　　} finally {
　　
　　　　　　if (ps!=null) ps.close();
　　
　　　　　　if (conn!=null)conn.close();
　　
　　　　　　}
　　
　　　　}
　　
　　　　public static void main(String argc[])
　　
　　　　{
　　
　　　　　　DbInput copydb=new DbInput();
　　
　　　　　　copydb.dbInit();
　　
　　　　　　copydb.copyprodUCt();　
　　
　　　　}　
　　
　　}
　　
　　問題：
　　
　　1)　　　 access 數據庫不能直接由jdbc讀寫，解決辦法是先把access配置在ODBC中，然后再通過ODBC來操作access數據庫。

上一篇：Java與XML聯合編程之SAX篇

下一篇：JAVA的XML編程