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();
		
	}

}

保存，而后右键执行，能够看到以下结果