码迷,mamicode.com
首页 > 数据库 > 详细

6.JDBC简单学习(使用IDEA)

时间:2018-07-28 13:55:41      阅读:191      评论:0      收藏:0      [点我收藏+]

标签:driver   管理   pen   nbsp   固定   快捷键   into   connector   connect   

一、准备工作,安装数据库(mysql,oracle等)

二、

1)打开IDEA,创建一个新的project

2)在新创建的project下新建一个Directory,用于存放连接mysql数据库需要使用的jar包。命名为libs。之后把“mysql-connector-java-5.1.42.jar”包粘贴进去。

技术分享图片

3)选中该project,使用快捷键control+shift+alt+s,在左边窗口选择Modules,右边窗口选择Dependencies,点击图中“”+“”号,把jar包添加进去,再点apply。

技术分享图片

4)到这里,基本上已经创建成功,接下来就是代码部分。

import java.sql.*;

/**
 * @author Vi
 * @create 2018-07-28
 * 测试数据库
 */
public class jdbcTest {
    //mysql驱动包名
    private static final String DRIVER_NAME = "com.mysql.jdbc.Driver";
    //数据库连接地址
    private static final String URL = "jdbc:mysql://127.0.0.1:3306/shopmanagement";
    //用户名
    private static final String USER_NAME = "root";
    //密码
    private static final String PASSWORD = "root";

    public static void main(String[] args) {
        Connection conn = null;

        try {
            //加载mysql的驱动类
            Class.forName(DRIVER_NAME);
            //获取数据库连接
            conn = DriverManager.getConnection(URL,USER_NAME,PASSWORD);
            //mysql查询语句
            String sql = "SELECT * FROM demo";

            PreparedStatement prst = conn.prepareStatement(sql);

            //结果集
            ResultSet rs = prst.executeQuery();
            while(rs.next()) {
                System.out.println("用户名:" +rs.getString("name")+"----密码:"+rs.getString("password"));
            }
            rs.close();
            prst.close();
        } catch (Exception e) {

            e.printStackTrace();
        } finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

测试结果:

技术分享图片

 

三、JDBC开发步骤

    1. 导入jar包
    2. 加载驱动程序 
      Class.forName(“com.mysql.jdbc.Driver”); //固定写法
    3. 获取数据库连接 
      Connection connection = DriverManager.getConnection(url,user,password); 
      url格式: 
      主协议:子协议://主机:端口/数据库名称 
      jdbc :mysql :// localhost:3306/mydatabase 
      user:数据库用户名 
      password:连接数据库密码

      DriverManager类:管理JDBC驱动服务类,主要功能是获取Connection对象

    4. 通过Connection创建Statement对象 
      Connection类: 代表数据库连接,要想访问数据库,必须先获得数据库连接
    5. 使用Statement对象来执行SQL语句,CRUD等操作,返回一个ResultSet对象
    6. ResultSet操作结果集 
      next()方法:用于判断是否有下一条记录。如果有返回true,并且让游标向下移动一行,如果没有返回false。

      getXxx()方法:获取当前游标指向的这条记录中的列数据。如:getInt(),getString(),getDate(),getDouble()等

    7. 回收资源

四、JDBC相应API简介。

(1)定义记录的类

class Person {
    private String id;
    private String name;
    private String sex;
    private String age;

    public Person(String name,String sex,String age) {
        this.name = name;
        this.sex = sex;
        this.age = age;
        this.id = null; //default
    }

    public String getName() {
        return name;
    }

    public String getSex() {
        return sex;
    }

    public String getAge() {
        return age;
    }

    public void setName(String name) {
        this.name = name;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public void setAge(String age) {
        this.age = age;
    }
}

2)获取连接

    private static Connection getConnection() {
        String driver ="com.mysql.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "root";
        Connection conn = null;
        try {
            Class.forName(driver);  //加载对应驱动
            conn = DriverManager.getConnection(url,user,password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }

3)insert

    private static int insert(Person person) {
        Connection conn = getConnection();
        int i = 0;
        String sql = "insert into person (name,sex,source) values(?,?,?)";
        PreparedStatement pstmt =null;
        try {
            pstmt = (PreparedStatement) conn.prepareStatement(sql);
            pstmt.setString(1,person.getName());
            pstmt.setString(2,person.getSex());
            pstmt.setString(3,person.getFrom());
            i = pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return i;
    }

4)update

    private static int update(Person person) {
        Connection conn = getConnection();
        int i = 0;
        String sql = "update person set source=‘"+person.getFrom()+"‘ where name=‘"+person.getName()+"‘";
        PreparedStatement pstmt;
        try {
            pstmt = (PreparedStatement)conn.prepareStatement(sql);
            i = pstmt.executeUpdate();
            System.out.println("result:"+i);
            pstmt.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return i;
    }

5)select

private static void getAll() {
        Connection conn = getConnection();
        String sql = "select * from person";
        PreparedStatement pstmt = null;
        try {
            pstmt = (PreparedStatement)conn.prepareStatement(sql);
            ResultSet rs = pstmt.executeQuery();
            int col = rs.getMetaData().getColumnCount();
            System.out.println("=========================================");
            while(rs.next()) {
                for (int i = 1; i <= col; i++) {
                    System.out.print(rs.getString(1)+"\t");
                    if((i==2) && (rs.getString(i).length() < 8)) {
                        System.out.print("\t");
                    }
                }
                System.out.println();
            }
            System.out.println("=========================================");
            pstmt.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }

6)delete

    private static int delete(String name) {
        Connection conn = getConnection();
        int i = 0;
        String sql = "delete from person where name=‘"+name+"‘";
        PreparedStatement pstmt = null;
        try {
            pstmt = (PreparedStatement)conn.prepareStatement(sql);
            i = pstmt.executeUpdate();
            System.out.print("删除了:"+i+"条数据");
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        return i;
    }

测试:

 public static void main(String[] args) {
        //增加数据
//        Person p1 = new Person("爱德华艾尔利克","男","钢之炼金术师");
//        Person p2 = new Person("温莉洛克贝尔","女","钢之炼金术师");
//
//        System.out.println(insert(p1));
//        System.out.println(insert(p2));
        //修改
//        Person p = new Person("樱木花道","男","灌篮高手");
//        update(p);
        //删除
       System.out.println(delete("爱德华艾尔利克"));
        //查询
        getAll();
    }

测试结果:

技术分享图片

代码分析

  在上述对数据库进行增删改查的过程中,可以发现其共性部分,即通用的流程:

  (1)创建Connection对象、SQL查询命令字符串;

  (2)对Connection对象传入SQL查询命令,获得PreparedStatement对象;

  (3)对PreparedStatement对象执行executeUpdate()或executeQurey()获得结果;

  (4)先后关闭PreparedStatement对象和Connection对象。

  可见,使用JDBC时,最常打交道的是Connection、PreparedStatement这两个类,以及select中的ResultSet类

 

6.JDBC简单学习(使用IDEA)

标签:driver   管理   pen   nbsp   固定   快捷键   into   connector   connect   

原文地址:https://www.cnblogs.com/blogforvi/p/9381257.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!