📄 databaseop.java
字号:
return v;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public Vector getMessageBack(int MessageNo){
Vector v=new Vector();
Statement stmt1=null;
ResultSet rs1=null;
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
stmt1=con.createStatement();
rs1=stmt1.executeQuery("select message_sendid,message_sub,message_sendtime,message_content from message_info where message_no="+MessageNo);
if(rs1.next()){
Vector v1=new Vector();
v1.add(0,rs1.getString(1));
v1.add(1,rs1.getString(2));
v1.add(2,rs1.getTimestamp(3));
v1.add(3,rs1.getString(4));
v.add(v1);
}
/* stmt2=con.createStatement();
rs2=stmt2.executeQuery("select back_fromid,back_sub,back_sendtime,back_content from back_info where back_tomessageno="+MessageNo);
while(rs2.next()){
Vector v2=new Vector();
//v1.add(0, Integer.toString(rs1.getInt(1)));
v2.add(0,rs2.getString(1));
v2.add(1,rs2.getString(2));
v2.add(2,rs2.getTime(3));
v2.add(3,rs1.getString(4));
v.add(v2);
}
*/
return v;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;}
public Vector getMessageList(int groupNo){
Vector v=new Vector();
Statement stmt1=null;
Statement stmt2=null;
ResultSet rs1=null;
ResultSet rs2=null;
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
stmt1=con.createStatement();
rs1=stmt1.executeQuery("select message_no,message_sub,message_sendid,message_sendtime,message_modifytime from message_info where message_groupno="+groupNo+" order by message_no");
stmt2=con.createStatement();
while(rs1.next()){
//rs2=stmt2.executeQuery("select count(back_no) from back_info where back_tomessageno="+rs1.getInt(1));
Vector v1=new Vector();
//v1.add(4, Integer.toString(rs1.getInt(1)));
v1.add(0,rs1.getString(2));
v1.add(1,rs1.getString(3));
v1.add(2,rs1.getTimestamp(4));//Time!!!!!!!
v1.add(3,rs1.getTimestamp(5));//time!!!!!!
v1.add(4,Integer.toString(rs1.getInt(1)));
v1.add(5,getBackCount(rs1.getInt(1)));
v.add(v1);
}
return v;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public int getBackCount(int messageNo){
ResultSet rs=null;
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt=con.prepareStatement("select count(back_no) from back_info where back_tomessageno=?");
pstmt.setInt(1, messageNo);
rs=pstmt.executeQuery();
if(rs.next())
return rs.getInt(1);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return 0;
}
public Vector getNotice(){
ResultSet rs=null;
Vector v=new Vector();
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt=con.prepareStatement("select notice_title,notice_content,notice_sendtime from notice_info order by notice_sendtime desc");
rs=pstmt.executeQuery();
while(rs.next()){
Notice notice =new Notice();
notice.setTitile(rs.getString("notice_title"));
notice.setContent(rs.getString("notice_content"));
notice.setSendtime(rs.getTimestamp("notice_sendtime"));
v.add(notice);
}
return v;
}
catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public User getUser(String id,String password){
ResultSet rs=null;
User user=null;
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt=con.prepareStatement("select user_id,user_password,user_authority,user_age,user_sex,user_qq,user_name from user_info where user_id=? and user_password=?");
pstmt.setString(1, id);
pstmt.setString(2, password);
rs=pstmt.executeQuery();
if(rs.next()){
user=new User();
user.setId(rs.getString("user_id"));
user.setPassword(rs.getString("user_password"));
user.setAuthority(rs.getInt("user_authority"));
user.setAge(rs.getInt("user_age"));
user.setSex(rs.getString("user_sex"));
user.setQq(rs.getString("user_qq"));
user.setName(rs.getString("user_name"));
return user;
}
}
catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public User getUser(String id){
ResultSet rs=null;
User user=null;
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt=con.prepareStatement("select user_id,user_password,user_authority,user_age,user_sex,user_qq,user_name from user_info where user_id=?");
pstmt.setString(1, id);
rs=pstmt.executeQuery();
if(rs.next()){
user=new User();
user.setId(rs.getString("user_id"));
user.setPassword(rs.getString("user_password"));
user.setAuthority(rs.getInt("user_authority"));
user.setAge(rs.getInt("user_age"));
user.setSex(rs.getString("user_sex"));
user.setQq(rs.getString("user_qq"));
user.setName(rs.getString("user_name"));
return user;
}
}
catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
public void updateBack(int backNo,Back back){
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt = con.prepareStatement("update back_info set back_sub=?,back_content=?,back_modifytime=CURRENT_TIMESTAMP() where back_no=?");
pstmt.setString(1,back.getSub());
pstmt.setString(2,back.getContent());
pstmt.setInt(3, backNo);
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public void updateMessage(int messageNo, Message message){
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt = con.prepareStatement("update message_info set message_sub=?,message_content=?,message_modifytime=CURRENT_TIMESTAMP() where message_no=?");
pstmt.setString(1,message.getSub());
pstmt.setString(2,message.getContent());
pstmt.setInt(3, messageNo);
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public void updateUser(User user){
try {
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/forum?useUnicode=true&characterEncoding=gbk","root","123");
PreparedStatement pstmt=con.prepareStatement("update user_info set user_password=?,user_age=?,user_sex=?,user_qq=?,user_name=? where user_id=?");
pstmt.setString(1, user.getPassword());
pstmt.setInt(2, user.getAge());
pstmt.setString(3, user.getSex());
pstmt.setString(4, user.getQq());
pstmt.setString(5, user.getName());
pstmt.setString(6, user.getId());
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -