ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

大数据第六课-Java(JBDC)连接数据库

2019-12-04 15:56:23  阅读:210  来源: 互联网

标签:JBDC java String 第六课 import sql System mysql Java


1、首先通过mysql -V查询本地mysql的版本。

 

2、下载对应版本的驱动包   mysql-connector-java-8.0.11.jar  :  https://maven.ityuan.com/maven2/mysql/mysql-connector-java/8.0.11   。

3、建立工程,添加驱动jar包。

4、添加以下内容,这个是测试连接的代码

package com.ygd.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class connMysql {

    public static void main(String[] args) {

        String driver = "com.mysql.cj.jdbc.Driver";
        // 获取mysql连接地址
        String url = "jdbc:mysql://localhost:3306/java_mysql?&useSSL=false&serverTimezone=UTC";
        // 数据名称
        String username = "root";
        // 数据库密码
        String password = "ty";
        // 获取一个数据的连接
        Connection conn = null;
        try{
            Class.forName(driver);
            //getConnection()方法,连接MySQL数据库!
            conn=DriverManager.getConnection(url,username,password);
            if(!conn.isClosed())
            System.out.println("数据库连接成功!");
             //创建statement类对象,用来执行SQL语句!
            Statement Statement=conn.createStatement();
            //要执行的SQL语句
            String sql="select * from user" ;
            //ResultSet类,用来存放获取的结果集!
            ResultSet rs=Statement.executeQuery(sql);
            System.out.println("-------------------------------");
            System.out.println("执行结果如下所示:");  
            System.out.println("-------------------------------");  
            System.out.println("姓名" + "\t" + "性别"+"\t");  
            System.out.println("-------------------------------");  
            String id=null;
            String name=null;
            while(rs.next()){
                //获取‘学号’这列数据
                id=rs.getString("username");
                 //获取‘姓名’这列数据
                name=rs.getString("pwd");
                //获取‘数学成绩’这列数据
                System.out.println(id+'\t'+name);
             }
             rs.close();
             conn.close();
         }
         catch(ClassNotFoundException e){
             //数据库驱动类异常处理
        System.out.println("数据库驱动加载失败!");
        e.printStackTrace();
         }
        catch(SQLException e1){
        //数据库连接失败异常处理
         e1.printStackTrace();
        }
        catch(Exception e2){
        e2.printStackTrace();
        }
        finally{
             System.out.println("-------------------------------");  
            System.out.println("数据库数据获取成功!");
        }

    }

}

5、向数据库中插入内容

package com.millionInsert.jbdc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Random;

import org.junit.Test;

public class millInsert {
    
    private String url = "jdbc:mysql://localhost:3306/java_mysql_mill?&useSSL=false&serverTimezone=UTC";
    private String user = "root";
    private String password = "ty";
    @Test
    public void Test(){
        Connection conn = null;
        PreparedStatement pstm =null;
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            conn = DriverManager.getConnection(url, user, password);        
            String sql = "INSERT INTO userinfo(uname,uphone,uaddress) VALUES(CONCAT('姓名',?),?,?)";
            pstm = conn.prepareStatement(sql);
            conn.setAutoCommit(false);
            Long startTime = System.currentTimeMillis();
            Random rand = new Random();
            int a,b,c,d;
            for (int i = 1; i <= 100000; i++) {

                    pstm.setInt(1, i);
                    a = rand.nextInt(10);
                    b = rand.nextInt(10);
                    c = rand.nextInt(10);
                    d = rand.nextInt(10);
                    pstm.setString(2, "188"+a+"88"+b+c+"66"+d);
                    pstm.setString(3, "xxxxxxxxxx_"+"188"+a+"88"+b+c+"66"+d);
                    pstm.executeUpdate();
            }
            conn.commit();
            Long endTime = System.currentTimeMillis();
            System.out.println("OK,用时:" + (endTime - startTime)); 
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }finally{
            if(pstm!=null){
                try {
                    pstm.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }
            }
        }
    }

}

 

 

标签:JBDC,java,String,第六课,import,sql,System,mysql,Java
来源: https://www.cnblogs.com/tyh666/p/11983325.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有