2.使用jodd 操作mysql数据库

摘要: 将自己学过在知识梳理一遍

接着上一个博客

新建class类JDBC.JAVA



由于操纵mysql数据库需要第三方的jar包，而为了jar包依赖管理，现在将项目转换为maven项目。

现在的项目的图标是这样子的




使用默认选项



新的项目结构



maven项目的配置文件，需要第三方的jar包都这在这里配置。



完成本项目需要mysql的jdbc驱动，可以在搜索引擎中直接搜索maven mysql



可以罗列出版本已经相关信息，点击需要的版本（跟mysql的版本相对应），例如mysql版本为5.5.49，那么jar文件的版本为5.1.39，如果要查询mysql数据库与jdbc驱动版本之间的关系，可以先去搜。。。



这里可以看到maven需要添加的配置文件



修改原来项目的配置文件，加入相应的jar文件，

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion>
<groupId>hello</groupId>
<artifactId>hello</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.17</version>
</dependency>
<dependency>
<groupId>org.jodd</groupId>
<artifactId>jodd-db</artifactId>
<version>3.7.1</version>
</dependency>
</dependencies>
<build>
<sourceDirectory>src</sourceDirectory>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.3</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>

eclipse中的maven插件就会自动帮我们下载相关的jar包，前提是你联网了。如果没有联网需要手动下载jar文件，然后添加到项目中。

修改JDBC.javaa文件

package db;

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

import jodd.db.DbQuery;

public class JDBC {

public static void main(String[] args) throws Exception {
// 获取链接
Class.forName("com.mysql.jdbc.Driver");
Connection connect = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8","root","");

// 新增表
DbQuery query = new DbQuery(connect ,"CREATE TABLE IF NOT EXISTS Persons("
+ "Id_P int,LastName varchar(255),"
+ "FirstName varchar(255),"
+ "Address varchar(255),"
+ "City varchar(255))");
query.executeUpdate();

query.close();

//新增数据
query = new DbQuery(connect ,"INSERT INTO Persons (LastName, Address) VALUES ('Wilson', 'Champs-Elysees')");
query.executeUpdate();

query.close();

// 查询数据
query = new DbQuery(connect,"SELECT * FROM Persons");
ResultSet rs = query.execute();
while(rs.next()){
String lastName = rs.getString("LastName");
String address = rs.getString("Address");
System.out.println("lastName=" + lastName + ",address=" + address);
}

query.close();

// 删除数据
query = new DbQuery(connect ,"DELETE FROM Persons WHERE LastName='Wilson' ");
int delnum = query.executeUpdate();
System.out.println("共删除" + delnum + "条数据");

query.close();

}

}

保存，然后右键执行，可以看到如下结果