CreateDB.java

package com.tools.db;

import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * @author zotall
 */
public class CreateDB {
 private Connection con=null;
 private Statement stmt=null;
 private String driver="com.mysql.jdbc.Driver";
 private String url="jdbc:mysql://localhost/db_zigbee";
 private String user="root";
 private String password="root";
 
 /**
  * 构造函数
  */
 public CreateDB(){
  connection();
 }
 
 /**
  * 创建连接
  */
 private void connection()
 {
  try{
   Class.forName(driver);
   con=DriverManager.getConnection(url,user,password);
   stmt=con.createStatement();
  }
  catch(Exception e){
   e.printStackTrace();
  }
 }
 
 /**
  * 插入数据
  */
 public void add(int equipId,int temperature,int smoke,int humidity,int voltage,int isurgent){
  Date dt=new Date();
  SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String nowTime=df.format(dt);
  String sql="insert into node(equipId,temperature,smoke,humidity,voltage,updateTime,isurgent)value('"+
  equipId+"','"+temperature+"','"+smoke+"','"+humidity+"','"+voltage+"','"+nowTime+"','"+isurgent+"',)";
  try{
   stmt.execute(sql);
  }
  catch(SQLException e)
  {
   e.printStackTrace();
  }
 }
 /**
  * 更新数据
  */
 public void update(int equipId,int temperature,int smoke,int humidity,int voltage,int isurgent){
  Date dt=new Date();
  SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String nowTime=df.format(dt);
  String sql="update node set temperature='"+temperature+"',smoke='"+smoke+"',humidity='"+humidity+"',voltage='"+voltage+"'," +
    "updateTime='"+nowTime+"',isurgent='"+isurgent+"' where equipId='"+equipId+"'";
  try{
   stmt.executeUpdate(sql);
  }
  catch(SQLException e)
  {
   e.printStackTrace();
  }
 }
 /**
  * 查询节点数据是否存在那个数据中,如果存在就更新
  */
 public boolean search(int equipId){
  boolean exist=false;
  String sql="select * from node where equipId='"+equipId+"'";
  try{
   ResultSet rs=stmt.executeQuery(sql);
   if(rs.next())
   {
    exist=true;
   }
  }catch(SQLException e){
   
  }
  return exist;
 }
 /**
  *关闭连接
  */
  public void close(){
         try {
             if (con != null ) con .close();
             if (stmt != null ) stmt .close();
         }catch (Exception e){
             e.printStackTrace();
         }
     }
}