Java 之jdbc连接mysql数据库

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Java 之jdbc连接mysql数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4992字，纯文字阅读大概需要8分钟。

内容图文

package jdbc;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class JdbcUtils 
{    
    private static String url;
    private static String user;
    private static String password;
    static {
        try {
            //FileInputStream in = new FileInputStream(new File("./src/db.properties"));
            InputStream in = JdbcUtils.class.getResourceAsStream("/db.properties");
            Properties properties = new Properties();
            properties.load(in);
            Class.forName(properties.getProperty("driver"));
            url = properties.getProperty("url");
            user = properties.getProperty("user");
            password = properties.getProperty("password");
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    /**
     * 获取连接
     * @return
     */
    public static Connection getConnection() {
        try {
            return DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
    
    /**
     * 关闭连接
     */
    public static void close(Statement stateMent, Connection connection) {
        if (stateMent != null) {
            try {
                stateMent.close();
            } catch (SQLException e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
    }
    
}

package jdbc.statement;

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

import jdbc.JdbcUtils;

import org.junit.Test;

public class StateMentTest {

    @Test
    public void testInsert() {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "insert into test (name) values ('test')";
            int count = stmt.executeUpdate(sql);
            System.out.println(count);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            JdbcUtils.close(stmt, conn);
        }
    }
    @Test
    public void testUpdate() {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "update test set name = 'update' where id=4";
            int count = stmt.executeUpdate(sql);
            System.out.println(count);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            JdbcUtils.close(stmt, conn);
        }
    }
    @Test
    public void testDelete() {

        Connection conn = null;
        Statement stmt = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "delete from test where id=4";
            int count = stmt.executeUpdate(sql);
            System.out.println(count);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            JdbcUtils.close(stmt, conn);
        }
    }
    
    @Test
    public void testSelect() {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = JdbcUtils.getConnection();
            stmt = conn.createStatement();
            String sql = "select * from test";
            ResultSet resultSet = stmt.executeQuery(sql);
            while(resultSet.next()) {
                System.out.println(resultSet.getString("name"));
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            JdbcUtils.close(stmt, conn);
        }
    }
}

package jdbc.prepared;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import jdbc.JdbcUtils;

import org.junit.Test;

public class PreparedStateMent {
    
    @Test
    public void testInsert()
    {
        Connection conn = JdbcUtils.getConnection();
        String sql = "insert into test (name) values (?)";
        PreparedStatement pstmt = null;
        try {
            pstmt = conn.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS);
            pstmt.setString(1, "prepared");
            int count = pstmt.executeUpdate();
            ResultSet resultSet = pstmt.getGeneratedKeys();
            if (resultSet.next()) {
                System.out.println(resultSet.getString(1));
            }
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally{
            JdbcUtils.close(pstmt, conn);
        }
    }
    
    @Test
    public void testUpdate()
    {
        Connection conn = JdbcUtils.getConnection();
        String sql = "update test set name = ? where id = ?";
        PreparedStatement pstmt = null;
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "prepareds");
            pstmt.setInt(2, 6);
            int count = pstmt.executeUpdate();
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally{
            JdbcUtils.close(pstmt, conn);
        }
    }
    @Test
    public void testDelete()
    {
        Connection conn = JdbcUtils.getConnection();
        String sql = "delete from test where id = ?";
        PreparedStatement pstmt = null;
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 6);
            int count = pstmt.executeUpdate();
            System.out.println(count);
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally{
            JdbcUtils.close(pstmt, conn);
        }
    }
    @Test
    public void testSelect()
    {
        Connection conn = JdbcUtils.getConnection();
        String sql = "select * from test";
        PreparedStatement pstmt = null;
        try {
            pstmt = conn.prepareStatement(sql);
            ResultSet set = pstmt.executeQuery();
            while(set.next()) {
                System.out.println(set.getString("name"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally{
            JdbcUtils.close(pstmt, conn);
        }
    }
}

内容总结

以上是互联网集市为您收集整理的Java 之jdbc连接mysql数据库全部内容，希望文章能够帮你解决Java 之jdbc连接mysql数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端