Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public void getMyMessageServer(String UserId, PrintWriter pr){
- String from=null;
- String message=null;
- String time=null;
- String date =null;
- Connection connection;
- Statement statement;
- ResultSet resultSet;
- try {
- Class.forName("com.mysql.jdbc.Driver");
- connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/product_database", "root", "");
- System.out.println("Product Share Database Opened...");
- statement = connection.createStatement();
- String sql="SELECT * FROM `message_data` WHERE `MessageTo`='"+UserId+"'"+"ORDER BY `MessageNo` DESC" ;
- //String sql="SELECT * FROM product WHERE ip_address= '"+address+"'";
- System.out.println("sql="+sql);
- resultSet=statement.executeQuery(sql);
- while (resultSet.next()) {
- from = resultSet.getString("MessageFrom");
- message= resultSet.getString("Message");
- time= resultSet.getString("Time");
- date= resultSet.getString("Date");
- System.out.println("Uploader name from db(tan)=" + from+"\t"+message+"\t"+time+"\t"+date);
- pr.println(from+"#"+message+"#"+time+"#"+date);
- }
- connection.close();
- pr.println("AllReceivedSentFromServer");
- }catch (Exception e){
- e.printStackTrace();
- System.out.println("Problem loading database");
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement