-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathProfile_edit_server.java
More file actions
101 lines (73 loc) · 2.92 KB
/
Copy pathProfile_edit_server.java
File metadata and controls
101 lines (73 loc) · 2.92 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.sql.*;
import java.util.Arrays;
public class Profile_edit_server extends Thread {
public static void main(String[] args) throws Exception{
byte[] bf = new byte[1500];
DatagramPacket dp = new DatagramPacket(bf, bf.length);
DatagramSocket ds=new DatagramSocket(9998);
while (true) {
bf = new byte[1500];
dp = new DatagramPacket(bf, bf.length);
ds.receive(dp);
Integer pt = dp.getPort();
InetAddress ia = dp.getAddress();
String Name = new String(bf).trim();
bf= new byte[1500];
Arrays.fill(bf,(byte)0);
dp= new DatagramPacket(bf, bf.length,ia,pt);
ds.receive(dp);
String State = new String(bf).trim();
bf= new byte[1500];
Arrays.fill(bf,(byte)0);
dp= new DatagramPacket(bf, bf.length,ia,pt);
ds.receive(dp);
String fileName = new String(bf).trim();
bf= new byte[1500];
Arrays.fill(bf,(byte)0);
dp= new DatagramPacket(bf, bf.length,ia,pt);
ds.receive(dp);
String ID = new String(bf).trim();
new Thread(new Capitalizer(ds,dp, bf, Name, State, fileName, ID)).start();
Thread.sleep(100);
}
}
private static class Capitalizer implements Runnable{
private DatagramSocket ds;
private byte[] bf = new byte[1500];
private DatagramPacket dp = new DatagramPacket(bf, bf.length);
private String Name, State, fileName, ID;
Capitalizer(DatagramSocket ds, DatagramPacket dp,byte[] bf, String Name, String State, String fileName, String ID){
this.ds = ds;
this.dp = dp;
this.bf = bf;
this.Name = Name;
this.State = State;
this.fileName = fileName;
this.ID = ID;
}
@Override
public void run(){
try {
Integer pt = dp.getPort();
InetAddress ia = dp.getAddress();
Connection con = null;
Class.forName("com.mysql.cj.jdbc.Driver");
con = DriverManager.getConnection("jdbc:mysql://localhost/network", "root", "1234");
String SQL = "update user user set name = ?, msg = ?, profile_img = ? where id = ?";
PreparedStatement pstmt = con.prepareStatement(SQL);
pstmt.setString(1,Name);
pstmt.setString(2,State);
pstmt.setString(3,fileName);
pstmt.setString(4,ID);
pstmt.executeUpdate();
pstmt.close();
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
}