疯狂java


您现在的位置: 疯狂软件 >> 新闻资讯 >> 正文

java连接mysql数据库


 

  java连接mysql数据库,步骤如下

  1、新建一个Java程序,导入mysql驱动包,驱动包网上可以找到,我用的是这个mysql-connector-java-5.0.8-bin

  2、添加DB.properties文件。需要注意的是这个文件必须添加到src文件夹下才能被读取,然后修改ip和端口号数和据库名,还有mysql的用户名和密码

  encoding=utf-8

  url=jdbc:mysql://192.1.1.1:3306/dbname?useUnicode=true&characterEncoding=utf-8

  username=root

  password=123456

  driver=com.mysql.jdbc.Driver

  3、剩下的就是简单的代码了。网上可以搜到很多DButil工具类,我用的是这个。把我注释掉的那段代码取消注释,这个工具类就可以直接运行,数据库就连上了

  package com.most.common.util;

  import java.io.FileNotFoundException;

  import java.io.IOException;

  import java.io.InputStream;

  import java.sql.Connection;

  import java.sql.DriverManager;

  import java.sql.SQLException;

  import java.util.Properties;

  /**

  * 数据库工具类

  *

  * @author way

  *

  */

  public class DButil {

  /**

  * 连接数据库

  *

  * @return 数据库连接对象

  */

  public static Connection connect() {

  Properties pro = new Properties();

  String driver = null;

  String url = null;

  String username = null;

  String password = null;

  try {

  InputStream is = DButil.class.getClassLoader()

  .getResourceAsStream("DB.properties");

  // System.out.println(is.toString());

  pro.load(is);

  driver = pro.getProperty("driver");

  url = pro.getProperty("url");

  username = pro.getProperty("username");

  password = pro.getProperty("password");

  // System.out.println(driver + ":" + url + ":" + username + ":"

  // + password);

  Class.forName(driver);

  Connection conn = DriverManager.getConnection(url, username,

  password);

  return conn;

  } catch (FileNotFoundException e) {

  e.printStackTrace();

  } catch (IOException e) {

  e.printStackTrace();

  } catch (ClassNotFoundException e) {

  e.printStackTrace();

  } catch (SQLException e) {

  e.printStackTrace();

  }

  return null;

  }

  /**

  * 关闭数据库

  *

  */

  public static void close(Connection con) {

  if (con != null) {

  try {

  con.close();

  } catch (SQLException e) {

  e.printStackTrace();

  }

  }

  }

  // public static void main(String[] args) {

  // Connection con = new DButil().connect();

  // System.out.println(con);

  // }

  }

  我们只是it农民工,不是搞学术研究的,能把事情做出来就好了,尤其在工作的时候,代码能复制就复制,工具类能用就用,工作不像学习,不需要去钻研每一句代码,效率才是最重要,这也是一种能力。

  数据库连上后,剩下的就是增删查改的操作了

  查

  Connection con = DButil.connect();

  String sql = "select * from table where id = 0 ";

  try {

  PreparedStatement ps = con.prepareStatement(sql);

  ResultSet rs = ps.executeQuery();

  while (rs.next()) {

  rs.getInt("id");

  rs.getString("name");

  rs.getInt("delete_flag");

  }

  } catch (SQLException e) {

  System.out.println(e.getMessage());

  // e.printStackTrace();

  } finally {

  DButil.close(con);

  }

  改

  sql = "update table set name=1 where user_id=? and friend_id = ?";

  ps = con.prepareStatement(sql);

  ps.setInt(1, id));

  ps.setInt(2, name);

  ps.executeUpdate();

  增和改的差不多,只是sql文不同String sql = "insert into table(name, id) values(?,?)";

  删除的话现在一般都不用物理删除了,设置一个flag标志是否删除,所以删除操作和修改一样

  String sql = "update table set delete_flag = 1 where id = ?";