package Dao;
import java.sql.*;
public class message {
	private Connection con=null;
	private Statement st=null;
	private PreparedStatement ps=null;
	private ResultSet rs=null;
	public final static String driver="com.mysql.jdbc.Driver";
	public final static String uri="jdbc:mysql://localhost:3306/News";
	public final static String name="root";
	public final static String password="123456";
	
	//建立数据库连接
	public void getConn(){
		try{
			Class.forName(driver); //加载驱动类
			con=DriverManager.getConnection(uri, name, password);
			System.out.println("数据库已连接");
		}
		catch (ClassNotFoundException e) {
			// TODO: handle exception
			System.out.println("驱动类未找到"+e.toString());
		}
		catch (SQLException e) {
			// TODO: handle exception
			System.out.println("连接对象创建失败"+e.toString());
		}
	}
	
	//发布公告
	 public int insertmessage(String content){
		 int i=0;
		 String sql="insert into message(content) values (?)";
		 try{
			 ps=con.prepareStatement(sql);
			 ps.setString(1, content);
			 i=ps.executeUpdate();
		 }
		 catch (SQLException e) {
			// TODO: handle exception
			 e.printStackTrace();
		}
		 return i;
	 }
	 
	
	 
	 //查询公告所有信息
	 public ResultSet findAll(){
		 String sql="select * from message";
		 try{
			 st=con.createStatement();
			 rs=st.executeQuery(sql);
		 }
		 catch (SQLException e) {
			// TODO: handle exception
			 e.printStackTrace();
		}
		 return rs;
	 }
	 
}