首页 > MySQL > mysql数据库的连接以及增删改查Java代码实现(Statement版)
2015
05-25

mysql数据库的连接以及增删改查Java代码实现(Statement版)

数据库:

[sql]

  1. create table t1(id int primary key not null auto_increment,name varchar(32),password varchar(32));
  2. insert into t1(name,passwordvalues(‘admin’,‘123’);
  3. insert into t1(name,passwordvalues(‘zhangsan’,‘123’);
  4. insert into t1(name,passwordvalues(‘lisi’,‘123’);

Java代码:

mysqlDao.java:

[java]
  1. package com.dao;
  2. import java.sql.Connection;
  3. import java.sql.DriverManager;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  7. import org.junit.Test;
  8. public class mysqlDao {
  9.     private static String driver=“com.mysql.jdbc.Driver”;     //驱动
  10.     private String url=“jdbc:mysql://localhost:3306/test”;    //数据库连接地址
  11.     private String user=“root”;     //数据库账户
  12.     private String password=“11”;      //数据库密码
  13.     private Connection connection=null;      //连接
  14.     private Statement stmt=null;      //声明
  15.     private ResultSet rs=null;     //结果集
  16.     private int i=-1;
  17.     /*
  18.      * 创建驱动
  19.      * */
  20.     static{
  21.         try {
  22.             Class.forName(driver);
  23.         } catch (ClassNotFoundException e) {
  24.             // TODO Auto-generated catch block
  25.             e.printStackTrace();
  26.         }
  27.     }
  28.     /*
  29.      * 加载驱动
  30.      * */
  31.     @Test
  32.     public void connect() {
  33.         // TODO Auto-generated method stub
  34.         try {
  35.             connection=DriverManager.getConnection(url, user, password);
  36.             if(connection!=null){
  37.                 System.out.println(“数据库连接成功!”);
  38.             }else{
  39.                 System.out.println(“数据库连接失败!”);
  40.             }
  41.         } catch (SQLException e) {
  42.             // TODO Auto-generated catch block
  43.             e.printStackTrace();
  44.         }
  45.     }
  46.     /*
  47.      * 执行sql语句
  48.      * */
  49.     public void doSql(String sql) {
  50.         // TODO Auto-generated method stub
  51.         System.out.println(“This Is mysqlDao.doSql() Method!”);
  52.         if(sql!=null){
  53.             connect();
  54.             try {
  55.                 stmt=connection.createStatement();
  56.                 stmt.execute(sql);
  57.             } catch (SQLException e) {
  58.                 // TODO Auto-generated catch block
  59.                 e.printStackTrace();
  60.             }
  61.         }
  62.     }
  63.     /*
  64.      * 获取影响行数
  65.      * */
  66.     public int getUpCount() {
  67.         // TODO Auto-generated method stub
  68.         try {
  69.             i=stmt.getUpdateCount();
  70.         } catch (SQLException e) {
  71.             // TODO Auto-generated catch block
  72.             e.printStackTrace();
  73.         }
  74.         return i;
  75.     }
  76.     /*
  77.      * 获取结果集
  78.      * */
  79.     public ResultSet getRs() {
  80.         try {
  81.             rs=stmt.getResultSet();
  82.         } catch (SQLException e) {
  83.             // TODO Auto-generated catch block
  84.             e.printStackTrace();
  85.         }
  86.         return rs;
  87.     }
  88.     /*
  89.      * 执行关闭方法
  90.      * */
  91.     public void close() {
  92.         // TODO Auto-generated method stub
  93.             try {
  94.                 if(rs!=null){
  95.                 rs.close();
  96.                 }
  97.             } catch (SQLException e) {
  98.                 // TODO Auto-generated catch block
  99.                 e.printStackTrace();
  100.             }finally{
  101.                     try {
  102.                         if(stmt!=null){
  103.                         stmt.close();
  104.                         }
  105.                     } catch (SQLException e) {
  106.                         // TODO Auto-generated catch block
  107.                         e.printStackTrace();
  108.                     }finally{
  109.                         if(connection!=null){
  110.                             try {
  111.                                 connection.close();
  112.                             } catch (SQLException e) {
  113.                                 // TODO Auto-generated catch block
  114.                                 e.printStackTrace();
  115.                             }
  116.                         }
  117.                     }
  118.                 }
  119.     }
  120. }

createSql.java

[java]
  1. package com.dao;
  2. import java.sql.ResultSet;
  3. import java.sql.SQLException;
  4. import org.junit.Test;
  5. public class createSql {
  6.     mysqlDao mysqldao=new mysqlDao();
  7.     private String sql;
  8.     private int i=-1;
  9.     private ResultSet rs=null;
  10.     /*
  11.      * 插入数据
  12.      * */
  13.     @Test
  14.     public void insert() {
  15.         // TODO Auto-generated method stub
  16.         sql=“insert into t1(name,password) values(‘lisi’,’1234′)”;    //创建sql语句
  17.         mysqldao.doSql(sql);    //执行sql语句
  18.         i=mysqldao.getUpCount();     //获取影响行数
  19.         if(i!=-1){
  20.             System.out.println(“数据插入成功!”);
  21.         }else{
  22.             System.out.println(“数据插入失败!”);
  23.         }
  24.         mysqldao.close();      //关闭连接
  25.     }
  26.     /*
  27.      * 删除数据
  28.      * */
  29.     @Test
  30.     public void delete() {
  31.         // TODO Auto-generated method stub
  32.         sql=“delete from t1 where id=6”;
  33.         mysqldao.doSql(sql);
  34.         i=mysqldao.getUpCount();
  35.         if(i!=-1){
  36.             System.out.println(“数据删除成功!”);
  37.         }else{
  38.             System.out.println(“数据删除失败!”);
  39.         }
  40.         mysqldao.close();
  41.     }
  42.     /*
  43.      * 修改数据
  44.      * */
  45.     @Test
  46.     public void update() {
  47.         // TODO Auto-generated method stub
  48.         sql=“update t1 set name=’wangwu’ where id=1”;
  49.         mysqldao.doSql(sql);
  50.         i=mysqldao.getUpCount();
  51.         if(i!=-1){
  52.             System.out.println(“数据更新成功!”);
  53.         }else{
  54.             System.out.println(“数据更新失败!”);
  55.         }
  56.         mysqldao.close();
  57.     }
  58.     /*
  59.      * 遍历数据
  60.      * */
  61.     @Test
  62.     public void select() throws SQLException {
  63.         // TODO Auto-generated method stub
  64.         sql=“select * from t1”;
  65.         mysqldao.doSql(sql);
  66.         rs=mysqldao.getRs();
  67.         if(rs!=null){
  68.             rs.last();
  69.             i=rs.getRow();
  70.             if(i>0){
  71.                 rs.beforeFirst();
  72.                 while(rs.next()){
  73.                     String id=rs.getString(“id”);
  74.                     String name=rs.getString(“name”);
  75.                     String password=rs.getString(“password”);
  76.                     System.out.println(“id:”+id+”  “+“name:”+name+”  password:”+password);
  77.                 }
  78.             }else{
  79.                 System.out.println(“对不起,没有您要查询的信息!”);
  80.             }
  81.         }else{
  82.             System.out.println(“异常………..”);
  83.         }
  84.         mysqldao.close();
  85.     }
  86. }

留下一个回复

你的email不会被公开。

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据