jdbc小demo

package com.erik.mysql_;


import com.erik.util.JdbcUtil;

import java.sql.*;

public class MysqlIndex {

    public static void main(String[] args) throws Exception {

        // 获取连接对象
        Connection connection = JdbcUtil.getConnection();
        // 开启事务
        connection.setAutoCommit(false);
        try {
            // 定义sql语句
            String sql = "SELECT * FROM USER where user_id = ?";

            PreparedStatement statement = connection.prepareStatement(sql);
            // 设置参数
            statement.setInt(1, 1);
            ResultSet resultSet = statement.executeQuery();


            while (resultSet.next()) {
                System.out.println(resultSet.getInt("user_id"));
                System.out.println(resultSet.getString("img"));
            }
            JdbcUtil.close(resultSet, statement, connection);
            connection.commit();
        } catch (Exception e) {
            connection.rollback();
            e.printStackTrace();
        }
    }
}

使用预处理技术

package com.erik.mysql_;


import com.erik.util.JdbcUtil;

import java.sql.*;

public class MysqlIndex {

    public static void main(String[] args) throws Exception {

        // 获取连接对象
        Connection connection = JdbcUtil.getConnection();
        // 定义sql语句
        String sql = "SELECT * FROM USER where user_id = ?";

        PreparedStatement statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1);
        ResultSet resultSet = statement.executeQuery();


        while (resultSet.next()) {
            System.out.println(resultSet.getInt("user_id"));
            System.out.println(resultSet.getString("img"));
        }
        JdbcUtil.close(resultSet, statement, connection);
    }
}

package com.erik.util;

import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

public class JdbcUtil {

    private static String driver;

    private static String url;
    private static String user;
    private static String password;


    static {
        Properties properties = new Properties();
        Class<JdbcUtil> aClass = JdbcUtil.class;
        String path = aClass.getClassLoader().getResource("pro.properties").getPath();
        try {
            properties.load(new FileReader(path));
            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            user = properties.getProperty("user");
            password = properties.getProperty("password");
            Class.forName(driver);
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }


    /**
     * 获取链接对象
     *
     * @return
     */
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, user, password);
    }

    public static void close(Statement statement, Connection connection) {
        if (statement != null) {
            try {
                statement.close();
            } catch (SQLException throwable) {
                throwable.printStackTrace();
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }

    public static void close(ResultSet resultSet, Statement statement, Connection connection) {
        if (statement != null) {
            try {
                resultSet.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        close(statement, connection);
    }
}

c3p0 的使用

简述：c3p0 是javax.sql.DataSource的实现类，数据库连接池的一种，还有druip,非常优秀，是阿里出品。

package com.erik.c3p0Test;


import com.mchange.v2.c3p0.ComboPooledDataSource;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class Index {

    public static void main(String[] args) throws SQLException {
        DataSource source = new ComboPooledDataSource();

        for (int i = 0; i <= 11; i++) {
            Connection connection = source.getConnection();
            System.out.println(i + ": " + connection);
        }
    }
}

配置文件

<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/book</property>
        <property name="user">root</property>
        <property name="password">root</property>

        <!--初始化连接的数量-->
        <property name="initialPoolSize">10</property>
        <!--等待时间-->
        <property name="maxIdleTime">3</property>
        <!--最大连接数-->
        <property name="maxPoolSize">10</property>
        <!--最小连接数-->
        <property name="minPoolSize">10</property>
    </default-config>

    <named-config name="mySource">
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/book</property>
        <property name="user">root</property>
        <property name="password">root</property>

        <property name="initialPoolSize">10</property>
        <property name="maxIdleTime">3</property>
        <property name="maxPoolSize">10</property>
        <property name="minPoolSize">10</property>
    </named-config>
</c3p0-config>

`druip` 的使用

package com.example.demoLogin.util;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;

public class JdbcUtil {

    private static DataSource ds;

    private static String driver;

    static {
        // 读取配置文件
        InputStream resourceAsStream = JdbcUtil.class.getClassLoader().getResourceAsStream("druid.properties");
        Properties properties = new Properties();
        try {
            properties.load(resourceAsStream);
            driver = properties.getProperty("driverClassName");
            // 导入驱动
            Class.forName(driver);
            // 初始化数据库连接池
            ds = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    /**
     * 获取数据源
     *
     * @return
     */
    public static DataSource getDatasource() {
        return ds;
    }


    /**
     * 获取连接池对象
     *
     * @return
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        return ds.getConnection();
    }

}

配置文件

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/book
username=root
password=root
initialSize=5
maxActive=10
maxWait=3000
maxIdle=8
minIdle=3

使用

package com.example.demoLogin.dao;

import com.example.demoLogin.doman.User;
import com.example.demoLogin.util.JdbcUtil;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;

import java.sql.SQLException;

public class UserDao {

    /**
     * 获取template
     */
    private JdbcTemplate template = new JdbcTemplate(JdbcUtil.getDatasource());

    /**
     * 获取用户
     * @param loginUser
     * @return
     * @throws SQLException
     */
    public User getUserById(User loginUser) throws SQLException {
        String name = loginUser.getName();
        String password = loginUser.getPassword();
        String sql = "SELECT * FROM USER WHERE name = ? and password = ?";
        User user = template.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), name, password);
        return user;
    }
}

jdbTemp

package com.erik.jdbcTmp;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;

import javax.sql.DataSource;
import java.util.List;
import java.util.Map;

public class JdbcTempDemo1 {

    public static void main(String[] args) {
        // 获取DataSource
        DataSource source = new ComboPooledDataSource(); // 也可以使用druip的连接池
        JdbcTemplate jdbcTemplate = new JdbcTemplate(source);
        String sql = "SELECT * FROM ADDRESS";
      // 封装为javaBean对象
        List<Address> query = jdbcTemplate.query(sql, new BeanPropertyRowMapper<Address>(Address.class));
        // jdbcTemplate.queryForList(sql);                  // 多条记录
        // jdbcTemplate.queryForMap(sql);                   // 单条记录
        // jdbcTemplate.queryForObject(sql, Long.class);  // 聚合函数
        System.out.println(query);

    }
}

package com.erik.jdbcTmp;

public class Address {

    private Integer address_id;

    private Integer user_id;

    private String name;

    private String phone_number;

    private Integer create_time;

    public Address() {
    }

    public Address(Integer address_id, Integer user_id, String name, String phone_number, Integer create_time) {
        this.address_id = address_id;
        this.user_id = user_id;
        this.name = name;
        this.phone_number = phone_number;
        this.create_time = create_time;
    }

    public Integer getAddress_id() {
        return address_id;
    }

    public void setAddress_id(Integer address_id) {
        this.address_id = address_id;
    }

    public Integer getUser_id() {
        return user_id;
    }

    public void setUser_id(Integer user_id) {
        this.user_id = user_id;
    }

    public String getName() {
        return name;
    }

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

    public String getPhone_number() {
        return phone_number;
    }

    public void setPhone_number(String phone_number) {
        this.phone_number = phone_number;
    }

    public Integer getCreate_time() {
        return create_time;
    }

    public void setCreate_time(Integer create_time) {
        this.create_time = create_time;
    }


    @Override
    public String toString() {
        return "Address{" +
                "address_id=" + address_id +
                ", user_id=" + user_id +
                ", name='" + name + '\'' +
                ", phone_number='" + phone_number + '\'' +
                ", create_time=" + create_time +
                '}';
    }
}

最后编辑于：2022.02.17 11:09:28

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 214,172评论 6赞 493
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 91,346评论 3赞 389
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 159,788评论 0赞 349
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 57,299评论 1赞 288
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 66,409评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 50,467评论 1赞 292
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,476评论 3赞 412
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 38,262评论 0赞 269
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,699评论 1赞 307
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,994评论 2赞 328
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 39,167评论 1赞 343
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,827评论 4赞 337
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,499评论 3赞 322
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 31,149评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,387评论 1赞 267
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 47,028评论 2赞 365
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 44,055评论 2赞 352

jdbc小demo

使用预处理技术

c3p0 的使用

druip 的使用

jdbTemp

推荐阅读更多精彩内容

`druip` 的使用