Java MySQL

Posted 2020-12-30 周先森

Java mysql

JDBC

Jdbc是一种Java连接数据库技术(Java database connectity), 它是 Java 提供的一些接口,这些接口大部分是数据库厂商提供的(jar包),我们要做的,是连接数据库以后,如何使用Java代码从数据库中存取数据!

 

JdbcDownload

https://dev.mysql.com/downloads/connector/j/

 

 

 

 

 

 

 

 

 

 

 

 

 

二选一即可

即可

 

添加jdbc.jar包

安装jdbc的包与下面添加包基本一致

 

选择当前项目—>【Build Path】-->【Configure Build Path...】。

1. 
2.  

   在打开的窗口中，先选中【Libraries】页，再从右边的按钮中点击

   【add JARs...】

   

3. 在打开的窗口中，我们依次展开本项目的项目和lib文件夹，然后选中我们刚才复制到项目中的jar包，然后点击【OK】关闭窗口

   

4. 此时，我们在刚才打开的【Libraries】页中可以看到我们引入的jar包的名称。点击【OK】确认。

   

 

tomcat的lib目录

这个是web服务器因为最后是他来提供服务，所以他的lib中也得把jdbc的包负责进去

Java Sql Deom

有一个测试版的java 封装好了的类

 

内容

我的jdbc是自动注册的所以不需要手动注册我下载的版本是比较新的

如果使用有问题，请手动注册

Class.forName("com.mysql.jdbc.Driver");

 

 

 

 

 

package com.db.jdbc;

 

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

 

public class DbUtil {

 

/**

* 连接数据

*

* @return conn

*/

    private static Connection conn;

public static void getConnection(String url,String username,String password) {

try {

conn = DriverManager.getConnection(url, username, password);

} catch (Exception e) {

e.printStackTrace();

}

}

 

/**

* 关闭连接对象

*

* @param conn

* 连接对象

* @param pstmt

* 预编译对象

* @param rs

* 结果集

*/

public static void closeAll(PreparedStatement pstmt, ResultSet rs) {

try {

if (rs != null) {

rs.close();

}

if (pstmt != null) {

pstmt.close();

}

if (conn != null) {

conn.close();

}

} catch (Exception e) {

e.printStackTrace();

}

}

 

/**

* 增删改操作

*

* @param sql

* SQL命令

* @param param

* 参数

* @return

*/

public static int executUpdate(String sql, Object[] param) {

int result = 0;

PreparedStatement pstmt = null;

try {

pstmt = conn.prepareStatement(sql);

if (param != null) {

for (int i = 0; i < param.length; i++) {

pstmt.setObject(i + 1, param[i]);

}

}

result = pstmt.executeUpdate();

} catch (Exception e) {

e.printStackTrace();

} finally {

closeAll(pstmt, null);

}

return result;

}

/**

* 查询

*

* @return int

* @date 2015-7-25 上午11:10:06

*/

public static ResultSet executQuery(String sql, String[] param) {

PreparedStatement pstmt = null;

ResultSet result = null;

try {

pstmt = conn.prepareStatement(sql);

if (param != null) {

for (int i = 0; i < param.length; i++) {

pstmt.setString(i + 1, param[i]);

}

}

result = pstmt.executeQuery();

} catch (Exception e) {

e.printStackTrace();

}

return result;

}

}

 

 

 

 

 

 

 

 

例子

例子使用

package com.jdbc.Test;

import java.sql.ResultSet;

import java.sql.SQLException;

 

import com.db.jdbc.DbUtil;

 

public class dbTest {

 

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

        // TODO 自动生成的方法存根

        String Url="jdbc:mysql://10.127.1.13:3306/monitor?serverTimezone=UTC&&useSSL=false";

        String UserName="root";

        String PassWord="redhat";

        DbUtil.getConnection(Url, UserName,PassWord);

        // 获取数据

        String Sql = "select * from dataInfo";

        ResultSet resultSet=DbUtil.executQuery(Sql, null);

        //逐行读取行的第一列数据

        while(resultSet.next())

        {

            System.out.print(resultSet.getString(0).toString()+"");

        }

          

        

        

    }

 

}