Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.sql.*;
- public class Connect
- {
- public static void main (String[] args)
- {
- Connection conn = null;
- try
- {
- String userName = "root";
- String password = "123";
- String url = "jdbc:mysql://localhost/typhoon";
- Class.forName ("com.mysql.jdbc.Driver").newInstance ();
- conn = DriverManager.getConnection (url, userName, password);
- System.out.println ("Database connection establiished");
- String query = "Select * From typhoon";
- Statement stmt = conn.createStatement();
- ResultSet rs = stmt.executeQuery(query);
- while (rs.next())
- {
- // this query for TEMP attribute
- String di = rs.getString(1);
- int result = di.compareTo("78");
- //System.out.print(result);
- if(result==0){ di="tm";}
- if(result>0) { di = "th";}
- else { di ="tl"; }
- // System.out.println(di);
- String query1 = "update typhoon set TEMP=" +"\"" + di+"\"";
- Statement stmt1 = conn.createStatement();
- stmt1.executeUpdate(query1);
- // this query for DEWP attribute
- String d1 = rs.getString(2);
- int result1 = d1.compareTo("70");
- if(result1==0){ d1="dm";}
- if(result1>0) { d1 = "dh";}
- else { d1 ="dl"; }
- System.out.println(d1);
- String query2 = "update typhoon set DEWP=" +"\"" + d1+"\"";
- Statement stmt2 = conn.createStatement();
- stmt2.executeUpdate(query2);
- // this query for WDSP attribute
- String d2 = rs.getString(3);
- int result2 = d2.compareTo("7.0");
- if(result2==0){ d2="wm";}
- if(result2>0) { d2 = "wh";}
- else { d2 ="wl"; }
- System.out.println(d2);
- String query3 = "update typhoon set WDSP=" +"\"" + d2+"\"";
- Statement stmt3 = conn.createStatement();
- stmt3.executeUpdate(query3);
- // this query for VISIB attribute
- String d3 = rs.getString(4);
- int result3 = d3.compareTo("4.7");
- if(result3==0){ d3="vm";}
- if(result3>0) { d3 = "vh";}
- else { d3 ="vl"; }
- System.out.println(d3);
- String query4 = "update typhoon set VISIB=" +"\"" + d3+"\"";
- Statement stmt4 = conn.createStatement();
- stmt4.executeUpdate(query4);
- // this query for PRCP attribute
- String d4 = rs.getString(5);
- int result4 = d4.compareTo("0");
- if(result4==0){ d4="yes";}
- else { d4 ="no"; }
- System.out.println(d4);
- String query5 = "update typhoon set PRCP=" +"\"" + d4+"\"";
- Statement stmt5 = conn.createStatement();
- stmt5.executeUpdate(query5);
- } //end while
- }
- catch (Exception e)
- {
- System.err.println ("Cannot connect to database server");
- }
- finally
- {
- if (conn != null)
- {
- try
- {
- conn.close ();
- System.out.println ("Database connection terminated");
- }
- catch (Exception e) { /* ignore close errors */ }
- }
- }
- }
- }
Add Comment
Please, Sign In to add comment