package dao;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
public class DAOartical {
public static java.util.ArrayList getAllArtical(String module) {
java.util.ArrayList list = new ArrayList();
entity.articalmessage artical = null;
dao.eduConnection eduCon = new eduConnection();
java.sql.Connection conn = eduCon.getConnection();
String sql = "select * from articalList where module=?";
PreparedStatement ps = null;
java.sql.ResultSet rs = null;
try {
ps = conn.prepareStatement(sql);
ps.setString(1, module);
rs = ps.executeQuery();
while (rs.next()) {
artical = new entity.articalmessage();
entity.usermessage user = new entity.usermessage();
user.setUserName(rs.getString("userName"));
artical.setUser(user);
artical.setTheme(rs.getString("theme"));
artical.setTime(rs.getString("time"));
artical.setContent(rs.getString("content"));
artical.setModule(rs.getString("module"));
list.add(artical);
}
} catch (Exception e) {
// TODO: handle exception
}
return list;
}
public static java.util.ArrayList getAllRecallArtical(String tableName) {
java.util.ArrayList list = new ArrayList();
entity.recallArtical recall = null;
dao.eduConnection eduCon = new eduConnection();
java.sql.Connection conn = eduCon.getConnection();
String sql = "select * from "+tableName;
PreparedStatement ps = null;
java.sql.ResultSet rs = null;
try {
ps = conn.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
recall = new entity.recallArtical();
entity.usermessage user = new entity.usermessage();
user.setUserName(rs.getString("userName"));
recall.setUser(user);
recall.setTime(rs.getString("time"));
recall.setContent(rs.getString("content"));
list.add(recall);
}
} catch (Exception e) {
// TODO: handle exception
}
return list;
}
public void addArtical(entity.usermessage user, String theme,
String content, String module) {
java.util.Calendar cal = Calendar.getInstance();
String month = String.valueOf(cal.get(cal.MONTH) + 1);
String time = String.valueOf(cal.get(cal.YEAR) + "_" + month + "_"
+ cal.get(cal.DAY_OF_MONTH) + "_" + cal.get(cal.HOUR_OF_DAY)
+ "_" + cal.get(cal.MINUTE) + "_" + cal.get(cal.SECOND) );
eduConnection eduCon = new eduConnection();
java.sql.Connection con = eduCon.getConnection();
String sql = "insert into articalList values (?,?,?,?,?)";
try {
java.sql.PreparedStatement ps = con.prepareStatement(sql);
ps.setString(1, user.getUserName());
ps.setString(2, theme);
ps.setString(3, time);
ps.setString(4, content);
ps.setString(5, module);
ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void addRecallArtical(entity.usermessage user,String content, String tableName) {
java.util.Calendar cal = Calendar.getInstance();
String month = String.valueOf(cal.get(cal.MONTH) + 1);
String time = String.valueOf(cal.get(cal.YEAR) + "年" + month + "月"
+ cal.get(cal.DAY_OF_MONTH) + "日" + cal.get(cal.HOUR_OF_DAY)
+ "点" + cal.get(cal.MINUTE) + "分" + cal.get(cal.SECOND) + "秒");
eduConnection eduCon = new eduConnection();
java.sql.Connection con = eduCon.getConnection();
String sql = "insert into "+tableName+" values (?,?,?)";
try {
java.sql.PreparedStatement ps = con.prepareStatement(sql);
ps.setString(1, user.getUserName());
ps.setString(2, time);
ps.setString(3, content);
ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public String createRecallArticalTable(entity.usermessage user) {
java.util.Calendar cal = Calendar.getInstance();
String month = String.valueOf(cal.get(cal.MONTH) + 1);
String time = String.valueOf(cal.get(cal.YEAR) + "_" + month + "_"
+ cal.get(cal.DAY_OF_MONTH) + "_" + cal.get(cal.HOUR_OF_DAY)
+ "_" + cal.get(cal.MINUTE) + "_" + cal.get(cal.SECOND));
String tableName = user.getUserName() + time;
eduConnection eduCon = new eduConnection();
java.sql.Connection con = eduCon.getConnection();
String sql = " CREATE TABLE "
+ tableName
+ " (`userName` varchar(10) default NULL,`time` varchar(100) default NULL,`content` varchar(1000) default NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8";
try {
java.sql.PreparedStatement ps = con.prepareStatement(sql);
ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return tableName;
}
public static void main(String[] args) {
dao.DAOartical dao = new dao.DAOartical();
java.util.ArrayList list=dao.getAllArtical("java");
for(int i=0;i<list.size();i++){
entity.articalmessage artical=(entity.articalmessage)list.get(i);
System.out.println(artical.getUser().getUserName());
}
}
}
- 1
- 2
前往页