Java实现连接MySQL数据库（JDBC）

深碍√TFBOYSˉ_ 2022-05-17 21:11 217阅读 0赞

想要操作数据库，电脑需要已经转好了SQL数据库，怎么安装，大家可以在网上查下，借鉴下前人的经验。百度词条（Mysql下载与安装）

这里使用 java 语言与MySQL数据库相连，实现数据持久化操作。

需要用到Jar包：mysql-connector-java-5.1.40-bin.jar

可以在这里下载：

https://pan.baidu.com/s/1axOzC8QrdovvnHQz9D0qHw 密码: jwv7

另外关于SQL语句的使用，可以查看这个网站：

[http://www.w3school.com.cn/sql/index.asp][http_www.w3school.com.cn_sql_index.asp]（比较详细）

2 实例代码（基本增删改查测试）：

import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.PreparedStatement;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.util.ArrayList;  
import java.util.List;

public class TestJDBC \{

// 声明一个连接对象，用来获取数据库连接，注意此Connection来自java.sql.DriverManager; ，不要导入错了。  
    static Connection connection = null;  
    // 创建一个声明  
    static PreparedStatement pst=null;  
    static \{  
        String driver = "com.mysql.jdbc.Driver";  
        String url = "jdbc:mysql://localhost:3306/test";  
        String user = "\*\*\*\*";//Mysql名字  
        String password = "\*\*\*";//Mysql连接密码  
        // 注册数据库的驱动  
        try \{  
            Class.forName(driver);  
        \} catch (ClassNotFoundException e) \{  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        \}

// 获取数据库连接  
        try \{  
            connection = DriverManager.getConnection(url, user, password);  
        \} catch (SQLException e) \{  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        \}  
    \}

public static void main(String\[\] args) throws SQLException \{  
        List<Person> list=null;  
        addPerson();//增加用户  
        list=select();  
        for(Person p:list) \{  
            System.out.println(p.toString());  
        \}  
        System.out.println();//换行  
        updatePerson();//更改用户  
        list=select();  
        for(Person p:list) \{  
            System.out.println(p.toString());  
        \}  
        System.out.println();  
        deletePerson();//删除  
        list=select();  
        for(Person p:list) \{  
            System.out.println(p.toString());  
        \}  
    \}  
    //查找全部的User表格数据  
    public static List<Person> select() throws SQLException\{  
        List<Person> list=new ArrayList<Person>();  
        //创建查询语句  
        String sql="select\*from user";  
          
        // 定义一个结果集合，用来存放读取的数据  
        ResultSet rs = null;  
        //执行查询  
        pst=connection.prepareStatement(sql);  
        rs=pst.executeQuery();//得到结果集  
        Person p=null;  
        while(rs.next()) \{  
            p=new Person();  
            p.setName(rs.getString("name"));  
            p.setPassword(rs.getString("password"));  
            list.add(p);  
        \}  
          
        return list;  
    \}  
    //增加数据  
    public static void addPerson() throws SQLException \{  
        String sql="insert into user(name,password) values(?,?)";  
        pst=connection.prepareStatement(sql);  
        pst.setString(1,"haha");  
        pst.setString(2,"1241243");  
        pst.executeUpdate();//添加操作  
        System.out.println("添加成功");  
          
    \}  
    //进行更新  
    public static void updatePerson() throws SQLException \{  
        String sql="update user set name=? where name=?";  
        pst=connection.prepareStatement(sql);  
        pst.setString(1,"luu");  
        pst.setString(2,"123");  
        pst.executeUpdate();  
        System.out.println("更新完成");  
    \}  
    //进行删除  
    public static void deletePerson() throws SQLException \{  
        String sql="delete from user where name=?";  
        pst=connection.prepareStatement(sql);  
        pst.setString(1,"haha");  
        pst.executeUpdate();  
        System.out.println("删除完成");  
    \}  
\}

[http_www.w3school.com.cn_sql_index.asp]: http://www.w3school.com.cn/sql/index.asp