java数据库mysql连接

连接MySQL数据库需要在新建的项目中导入mysql的java连接驱动，我用的是：mysql-connector-java-5.0.4-bin。

• 加载MYSQL JDBC驱动程序

• Statement对象的创建:

Connection con=DriverManager.getConnection(url, "System", "new");
Statement stmt=con.createStatement();
ResultSet rs=stmt.ExecuteQuery("select * from new");

• 连接URL为 jdbc:mysql//服务器地址/数据库名 ，后面的2个参数分别是登陆用户名和密码

• 在命令行打印异常信息在程序中出错的位置及原因。

Statement提供了三种不同的方法来执行SQL语句:
ExecuteQuery: 用来返回一个单独的结果集ResultSet，用于sql查询
ExecuteUpdate: 用来执行insert, update 和 delete语句，返回值是一个整数
Execute: 则会返回一个或多个ResultSet对象， 可是更新数，或两者都有

package connectmySQL;
import java.sql.*;


public class sendMySQL {

    public static void main(String args[]) {
        Connection connect = null;
        PreparedStatement cmmd = null;
        ResultSet rs = null;


        try {
          Class.forName("com.mysql.jdbc.Driver");

         System.out.println("Success loading Mysql Driver!");
        }
        catch (Exception e) {
          System.out.print("Error loading Mysql Driver!");
          e.printStackTrace();
        }

        try {
              connect = DriverManager.getConnection( "jdbc:mysql://localhost:3306/dbyichun","root","123456");
              System.out.println("Success connect Mysql server!");
            }
            catch (Exception e) {
              System.out.print("Error loading Mysql Driver!");
              //在命令行打印异常信息在程序中出错的位置及原因。
              e.printStackTrace();
            }



        //查询
        try {
          String sql = "select * from tbluser";
            cmmd = (PreparedStatement)connect.prepareStatement(sql);
            //查询使用executeQuery()
            rs = cmmd.executeQuery();
          while (rs.next()) {
            System.out.println(rs.getString("id"));
            System.out.println(rs.getString("uname"));
            System.out.println(rs.getString("pwd"));
          }
          cmmd.close();
            }
            catch (Exception e) {
              System.out.print("get data error!");
              e.printStackTrace();
            }

        /*添加*/
        try {
              String sql = "INSERT INTO tbluser(uname,pwd) VALUES('da','123')";
              cmmd = (PreparedStatement)connect.prepareStatement(sql);
              //添加使用ExecuteUpdate，返回一个整数，为1添加成功，0则失败。
              int rows = cmmd.executeUpdate();
              System.out.println(rows != 0?"添加数据成功！" : "添加数据失败！");
              cmmd.close();
            }
            catch (Exception e) {
              System.out.print("get data error!");
              e.printStackTrace();
            }

        /*修改*/
        try {
              String sql = "UPDATE tbluser SET uname = 'hzm',pwd = '111' WHERE id = 1";
              cmmd = (PreparedStatement)connect.prepareStatement(sql);
              //修改/更新使用ExecuteUpdate，返回一个整数，为1添加/更新成功，0则失败。
              int rows = cmmd.executeUpdate();
              System.out.println(rows != 0?"修改数据成功！" : "修改数据失败！");
               cmmd.close();
            }
            catch (Exception e) {
              System.out.print("get data error!");
              e.printStackTrace();
            }
        /*删除*/
        try {
              String sql = "DELETE FROM tbluser WHERE id = 7";
              cmmd = (PreparedStatement)connect.prepareStatement(sql);
              //删除使用ExecuteUpdate，返回一个整数，为1删除成功，0则失败。
              int rows = cmmd.executeUpdate();
              System.out.println(rows != 0?"删除数据成功！" : "删除数据失败！");
              cmmd.close();
            }
            catch (Exception e) {
              System.out.print("get data error!");
              e.printStackTrace();
            }
      }
}