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

}

保存，而後右鍵執行，能夠看到以下結果