kevinli
/
tmp
0
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: kevinli:master
Branches Tags
kevinli:master
kevinli:vmware
kevinli:dockerAPI
kevinli:KubernetesMonitor
kevinli:newk8s
kevinli:training_project
kevinli:useful
kevinli:testk8s
kevinli:mysqlapi
..
compare: kevinli:dockerAPI
Branches Tags
kevinli:vmware
kevinli:dockerAPI
kevinli:KubernetesMonitor
kevinli:newk8s
kevinli:training_project
kevinli:useful
kevinli:testk8s
kevinli:master
kevinli:mysqlapi

No commits in common. "master" and "dockerAPI" have entirely different histories.
master ... dockerAPI

48 changed files with 564 additions and 1236 deletions
Show Stats Expand all files Collapse all files

26
.classpath Normal file
View File

@ -0,0 +1,26 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry kind="src" output="target/classes" path="src/main/java">
<attributes>
<attribute name="optional" value="true"/>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="src" output="target/test-classes" path="src/test/java">
<attributes>
<attribute name="optional" value="true"/>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/J2SE-1.5">
<attributes>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
<attributes>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="output" path="target/classes"/>
</classpath>

23
.project Normal file
View File

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>test</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
<buildCommand>
<name>org.eclipse.jdt.core.javabuilder</name>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.m2e.core.maven2Builder</name>
<arguments>
</arguments>
</buildCommand>
</buildSpec>
<natures>
<nature>org.eclipse.jdt.core.javanature</nature>
<nature>org.eclipse.m2e.core.maven2Nature</nature>
</natures>
</projectDescription>

4
.settings/org.eclipse.core.resources.prefs Normal file
View File

@ -0,0 +1,4 @@
eclipse.preferences.version=1
encoding//src/main/java=UTF-8
encoding//src/test/java=UTF-8
encoding/<project>=UTF-8

5
.settings/org.eclipse.jdt.core.prefs Normal file
View File

@ -0,0 +1,5 @@
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.5
org.eclipse.jdt.core.compiler.compliance=1.5
org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
org.eclipse.jdt.core.compiler.source=1.5

4
.settings/org.eclipse.m2e.core.prefs Normal file
View File

@ -0,0 +1,4 @@
activeProfiles=
eclipse.preferences.version=1
resolveWorkspaceProjects=true
version=1

4
challenge2.sql
View File

@ -1,4 +0,0 @@
drop database if exists bookstore;
create database bookstore;

17
challenge3.sql
View File

@ -1,17 +0,0 @@
drop database if exists bookstore;
create database bookstore;
use bookstore;
create table book(
id int(11) not NULL,
title VARCHAR(255),
author VARCHAR(255),
publisher VARCHAR(255),
publishYear int(11)
)DEFAULT CHARSET=utf8;
Insert into book (id,title,author,publisher,publishYear) values
(1002,'平凡的世界', '路遥','新世界出版社',2011),
(1026,'活着', '余华','东方出版社',2016),
(1204,'围城', '钱钟书','人名文学出版社',1991),
(1208,'围城', '钱钟书','文艺出版社',2012);

18
challenge4.sql
View File

@ -1,18 +0,0 @@
drop database if exists bookstore;
create database bookstore;
use bookstore;
create table book(
id int(11) not NULL,
title VARCHAR(255),
author VARCHAR(255),
publisher VARCHAR(255),
publishYear int(11)
)DEFAULT CHARSET=utf8;
Insert into book (id,title,author,publisher,publishYear) values
(1002,'平凡的世界', '路遥','新世界出版社',2011),
(1026,'活着', '余华','东方出版社',2016),
(1204,'围城', '钱钟书','人名文学出版社',1991),
(1208,'围城', '钱钟书','文艺出版社',2012),
(1004,'平凡的世界', '路遥','文艺出版社',2012),
(1010,'人生', '路遥','文艺出版社',2005),
(1024,'活着', '余华','作家出版社',2012);

16
challenge5.sql
View File

@ -1,16 +0,0 @@
drop database if exists bookstore;
create database bookstore;
use bookstore;
create table book(
id int(11) not NULL,
title VARCHAR(255),
author VARCHAR(255),
publisher VARCHAR(255),
publishYear int(11)
)DEFAULT CHARSET=utf8;
Insert into book (id,title,author,publisher,publishYear) values
(1002,'平凡的世界', '路遥','新世界出版社',2011),
(1204,'围城', '钱钟书','人名文学出版社',1991),
(1208,'围城', '钱钟书','文艺出版社',2012),
(1004,'平凡的世界', '路遥','文艺出版社',2012),
(1010,'人生', '路遥','文艺出版社',2005);

16
challenge6.sql
View File

@ -1,16 +0,0 @@
drop database if exists bookstore;
create database bookstore;
use bookstore;
create table book(
id int(11) not NULL,
title VARCHAR(255),
author VARCHAR(255),
publisher VARCHAR(255),
publishYear int(11)
)DEFAULT CHARSET=utf8;
Insert into book (id,title,author,publisher,publishYear) values
(1002,'平凡的世界', '路遥','新世界出版社',2011),
(1204,'围城', '钱钟书','人名文学出版社',1991),
(1208,'围城', '钱钟书','文艺出版社',2012),
(1004,'平凡的世界', '路遥','文艺出版社',2012),
(1010,'人生', '路遥','文艺出版社',2005);

18
challenge7.sql
View File

@ -1,18 +0,0 @@
drop database if exists bookstore;
create database bookstore;
use bookstore;
create table step7(
id int(11) not NULL,
title VARCHAR(255),
author VARCHAR(255),
publisher VARCHAR(255),
publishYear int(11)
)DEFAULT CHARSET=utf8;
Insert into step7 (id,title,author,publisher,publishYear) values
(1002,'平凡的世界', null,'新世界出版社',null),
(1208,null, '钱钟书',null,null);
create table transformedBook(
id int(11),
column_name VARCHAR(255),
value VARCHAR(255)
)DEFAULT CHARSET=utf8;

BIN
lib/ant.jar
View File

Binary file not shown.

BIN
lib/mysql-connector-java-5.1.41-bin.jar
View File

Binary file not shown.

46
pom.xml Normal file
View File

@ -0,0 +1,46 @@
<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>test</groupId>
<artifactId>test</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>test</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/io.fabric8/kubernetes-client -->
<dependency>
<groupId>io.fabric8</groupId>
<artifactId>kubernetes-client</artifactId>
<version>2.6.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.spotify/docker-client -->
<dependency>
<groupId>com.spotify</groupId>
<artifactId>docker-client</artifactId>
<version>8.9.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.github.docker-java/docker-java -->
<dependency>
<groupId>com.github.docker-java</groupId>
<artifactId>docker-java</artifactId>
<version>3.0.13</version>
</dependency>
</dependencies>
</project>

9
src/main/java/com/docker/api/CpuStats.java Normal file
View File

@ -0,0 +1,9 @@
package com.docker.api;
/**
* 获取系统CPU使用率，以监控整个集群的资源使用状况
* @author kevin
*
*/
public class CpuStats {
}

8
src/main/java/com/docker/api/DockerClient.java Normal file
View File

@ -0,0 +1,8 @@
package com.docker.api;
/**
* 提供docker的各种接口供资源监控使用
* @author kevin
*/
public class DockerClient {
}

8
src/main/java/com/docker/api/HealthStats.java Normal file
View File

@ -0,0 +1,8 @@
package com.docker.api;
/**
* 获取整个集群的健康状态，如平均编译运行时间、剩余内存及CPU
* @author kevin
*/
public class HealthStats {
}

9
src/main/java/com/docker/api/KubernetesClient.java Normal file
View File

@ -0,0 +1,9 @@
package com.docker.api;
/**
* 提供集群的各种信息如节点数量和地址，供资源监控使用
* @author kevin
*
*/
public class KubernetesClient {
}

9
src/main/java/com/docker/api/MemoryStats.java Normal file
View File

@ -0,0 +1,9 @@
package com.docker.api;
/**
* 获取整个集群的内存使用状态
* @author kevin
*
*/
public class MemoryStats {
}

178
src/main/java/test/test/App.java Normal file
View File

@ -0,0 +1,178 @@
package test.test;
import java.util.List;
import org.glassfish.jersey.internal.util.collection.StringIgnoreCaseKeyComparator;
import ch.qos.logback.core.net.server.Client;
import io.fabric8.kubernetes.api.model.Container;
import io.fabric8.kubernetes.api.model.ContainerBuilder;
import io.fabric8.kubernetes.api.model.KubernetesResource;
import io.fabric8.kubernetes.api.model.Namespace;
import io.fabric8.kubernetes.api.model.Node;
import io.fabric8.kubernetes.api.model.NodeAddress;
import io.fabric8.kubernetes.api.model.ObjectMeta;
import io.fabric8.kubernetes.api.model.Pod;
import io.fabric8.kubernetes.api.model.PodBuilder;
import io.fabric8.kubernetes.api.model.PodSpec;
import io.fabric8.kubernetes.client.Config;
import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.kubernetes.client.DefaultKubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.fabric8.kubernetes.client.Watcher;
import io.fabric8.kubernetes.client.utils.Utils;
/**
* Hello world!
*
*/
public class App
{
public static void main( String[] args )
{
Config config = new ConfigBuilder().
withMasterUrl("106.75.96.108:6443").
withNamespace("default").
withTrustCerts(true).
// withOauthToken("c7dd73a7c86992fb").
withUsername("testk8s").
withPassword("testk8s").
build();
// Pod pod = new PodBuilder().withKind("ReplictioController").withSpec(spec);
// ObjectMeta objectMeta;
PodSpec podSpec;
Container container = new ContainerBuilder().w
KubernetesClient client = new DefaultKubernetesClient(config);
client.pods();
//client.pods()
client.pods().list().getItems().get(0).getSpec();
//NodeAddress
List<NodeAddress> address = client.nodes().list().getItems().get(0).getStatus().getAddresses();
System.out.println(address.get(0).getAddress());
client.resource("pod").get();
// KubernetesResource<HasMetadata> kubernetesResource =
// List<Namespace> nameSpaceList =client.namespaces().list().getItems();
// List<Pod> pods = client.pods().list().getItems();
// testDeletePod(client, "docker-evaluate-1341-r8zz5");
// //假设我可以通过Pod查看容器的名字
// Container container = client.pods().withName("").get().getSpec().getContainers().get(0);
// //那么也就可以使用docker stat --nostream 查看容器的状态
// container.getResources();
// container.get
// watch(client,"docker-evaluate-1335-8gmsj");
//
// testDeletePod(client,"docker-evaluate-1335-8gmsj");
// System.out.println(pods.get(0).getMetadata().getName());
// System.out.println(nameSpaceList.size());
// testCreateNamespace(client);
}
public static void testCreateNamespace(KubernetesClient kubernetesClient){
Namespace ns = new Namespace();
ns.setApiVersion("v1");
ns.setKind("Namespace");
ObjectMeta om = new ObjectMeta();
om.setName("ns-fabric8");
ns.setMetadata(om);
kubernetesClient.namespaces().create(ns);
}
// public static void testCreatePod(KubernetesClient kubernetesClient){
//
// Pod pod = new Pod();
//
//// pod.setApiVersion("v1");
//// pod.setKind("ReplicationController");
//
// //设置pod的meta数据
// ObjectMeta om = new ObjectMeta();
// om.setName("webssh-master-wrmtest");
// Map<String,String> map = new HashMap<String,String>();
//
// pod.setMetadata(om);
//
//
// PodSpec spec =new PodSpec();
// spec.setNodeSelector(map);
//
//
// List<Container> containerList = new ArrayList<Container>();
// Container container = new Container();
// container.setName("webssh");
// container.setImage("dind-ssh:v1.0");
//
// SecurityContext securityContext = new SecurityContext();
// securityContext.setPrivileged(true);
// container.setSecurityContext(securityContext);
//
// spec.setContainers(containerList);
//
// pod.setSpec(spec);
//
// kubernetesClient.pods().create(pod);
//
// }
public static void testDeletePod(KubernetesClient kubernetesClient,String podName){
kubernetesClient.pods().withName(podName).delete();
}
public static void watch(KubernetesClient client,String podName) {
client.pods().withName(podName).watch(new Watcher<Pod>() {
public void eventReceived(Action action, Pod resource) {
// TODO Auto-generated method stub
System.out.println(action+":"+resource);
}
public void onClose(KubernetesClientException cause) {
// TODO Auto-generated method stub
System.out.println("closed"+cause);
}
});
}
}

52
src/main/java/test/test/DockerApiTest.java Normal file
View File

@ -0,0 +1,52 @@
package test.test;
import java.net.URI;
import java.util.List;
import com.spotify.docker.client.DefaultDockerClient;
import com.spotify.docker.client.DockerClient;
import com.spotify.docker.client.DockerClient.ListContainersParam;
import com.spotify.docker.client.auth.FixedRegistryAuthSupplier;
import com.spotify.docker.client.exceptions.DockerException;
import com.spotify.docker.client.messages.Container;
import com.spotify.docker.client.messages.ContainerState;
import com.spotify.docker.client.messages.ContainerStats;
import com.spotify.docker.client.messages.CpuStats;
import com.spotify.docker.client.messages.MemoryStats;
import com.spotify.docker.client.messages.RegistryAuth;
import io.netty.util.internal.SystemPropertyUtil;
import sun.audio.*;
public class DockerApiTest {
public static void main(String[] args) throws DockerException, InterruptedException{
// RegistryAuth registr = RegistryAuth.builder().serverAddress("http://106.75.95.215:4243/v1")
// .username("educoder")
// .password("educoder")
// .email("lqk_nudt@163.com")
// .build();
//172.17.0.1:2376
//10-9-186-111
final DockerClient docker = DefaultDockerClient.builder()
.uri(URI.create("http://106.75.96.108:4243"))
.build();
ListContainersParam param = new ListContainersParam("namespace", "default");
Container container = docker.listContainers(param).get(0);
String containerId = container.id();
MemoryStats memoryStats = docker.stats(containerId).memoryStats();
CpuStats cpuStats = docker.stats(containerId).cpuStats();
Long systemUsage = cpuStats.systemCpuUsage();
Long total = cpuStats.cpuUsage().totalUsage();
System.out.println("containerId: " + containerId);
System.out.println("systemUsage:" + systemUsage);
System.out.println("total:" + total);
// Long perCpu = cpuStats.cpuUsage().percpuUsage();
// System.out.println("CpuStats:" + cpuStats.cpuUsage() );
// System.out.println(memoryStats.usage().intValue());
}
}

87
src/main/java/test/test/DockerJava.java Normal file
View File

@ -0,0 +1,87 @@
package test.test;
import java.io.Closeable;
import java.io.IOException;
import com.github.dockerjava.api.DockerClient;
import com.github.dockerjava.api.async.ResultCallback;
import com.github.dockerjava.api.model.Identifier;
import com.github.dockerjava.api.model.PushResponseItem;
import com.github.dockerjava.api.model.Repository;
import com.github.dockerjava.core.DefaultDockerClientConfig;
import com.github.dockerjava.core.DockerClientBuilder;
import com.github.dockerjava.core.DockerClientConfig;
public class DockerJava {
public static void main(String[] args) {
DockerJava dockerJava = new DockerJava();
DockerClient dockerClient = dockerJava.getDockerClient("tcp://106.75.96.108:4243", "http://106.75.95.215:5000/v2/");
// System.out.println(dockerJava.getImageID(dockerClient, "gcc", "latest"));
dockerJava.pushToRegistry(dockerClient, "busybox", "latest");
}
public DockerClient getDockerClient(String host, String RegistryUrl)
{
DockerClientConfig config = DefaultDockerClientConfig.createDefaultConfigBuilder()
.withDockerHost(host)
.withDockerTlsVerify(false)
.withApiVersion("1.23")
.withRegistryUrl(RegistryUrl)
.build();
DockerClient docker = DockerClientBuilder.getInstance(config).build();
return docker;
}
public String getImageID(DockerClient docker, String imageName, String tag)
{
return docker.inspectImageCmd(imageName + ":" + tag).exec().getId();
}
public void pushToRegistry(DockerClient docker, String imageName, String imageTag)
{
PushResponseItem responseItem = new PushResponseItem();
// Repository repository = new Repository(imageName);
// Identifier identifier = new Identifier(repository, imageTag);
docker.pushImageCmd(imageName + ":" + imageTag).exec(resultCallback);
//docker.pushImageCmd(imageName + ":" + imageTag).exec(resultCallback)
}
ResultCallback<PushResponseItem> resultCallback = new ResultCallback<PushResponseItem>() {
public void close() throws IOException {
// TODO Auto-generated method stub
System.exit(0);
}
public void onStart(Closeable closeable) {
// TODO Auto-generated method stub
System.exit(0);
}
public void onError(Throwable throwable) {
// TODO Auto-generated method stub
System.exit(0);
}
public void onComplete() {
// TODO Auto-generated method stub
System.out.println("已经完成");
}
public void onNext(PushResponseItem object) {
// TODO Auto-generated method stub
System.out.println(object.getProgressDetail());
}
};
}

83
src/step1/MySQLWithJDBC.java
View File

@ -1,83 +0,0 @@
package step1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MySQLWithJDBC {
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "create database " + databaseName;
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
//创建数据库实例
public void dropDatabase(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "drop database if exists " + databaseName;
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
//获取数据库中已经存在的数据库实例
public ResultSet getExistDB(Connection connection, String databaseName) throws SQLException
{
ResultSet resultSet = null;
Statement stmt = null;
String sqlScript = "SELECT * FROM information_schema.SCHEMATA where SCHEMA_NAME=\"" + databaseName + "\"";
try {
stmt = (Statement) connection.createStatement();
resultSet = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return resultSet;
}
}

40
src/step1/MySQLWithJDBCTest.java
View File

@ -1,40 +0,0 @@
package step1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;
public class MySQLWithJDBCTest {
public static void main(String[] args) throws SQLException {
MySQLWithJDBC mysql = new MySQLWithJDBC();
String databaseName = "";
//从命令行接收输入获得数据库的名字
Scanner sc = new Scanner(System.in);
databaseName = sc.next();
//建立数据库连接
Connection connection = mysql.getConnection(mysql.JDBC_DRIVER, mysql.DB_URL, mysql.USER, mysql.PASS);
mysql.dropDatabase(connection,databaseName);
//执行创建数据库的命令
mysql.createDatabaseInstance(connection, databaseName);
//查询数据库验证是否成功创建
ResultSet result = mysql.getExistDB(connection, databaseName);
//获取查询结果
while(result.next())
{
String dbName = result.getString("SCHEMA_NAME");
System.out.print("databaseName:" + dbName);
}
}
}

108
src/step2/CreateTable.java
View File

@ -1,108 +0,0 @@
package step2;
import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
public class CreateTable {
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//在指定数据库实例中创建有tableName命名的表
public void createTable(Connection connection, String tableName,String[][] tableInfo){
//请在此处实现创建表的操作
String sqlScript = "create table " + tableName + "(\n";
Statement stmt = null;
for(int k=0;k<tableInfo.length;k++)
{
if(tableInfo[k][0].equals(""))
break;
System.out.println(tableInfo[k][0] + tableInfo[k][1]);
sqlScript = sqlScript + tableInfo[k][0] + " " + tableInfo[k][1] + ",\n";
}
sqlScript = sqlScript.substring(0, sqlScript.length()-2);
sqlScript = sqlScript + ")";
try {
stmt = connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
public ResultSet getExistTable(Connection conn,String databaseName,String tableName) {
ResultSet resultSet = null;
Statement stmt = null;
/*select TABLE_NAME from INFORMATION_SCHEMA.TABLES whereTABLE_SCHEMA='dbname' and TABLE_NAME='tablename' ;*/
String sqlScript = "select * from INFORMATION_SCHEMA.TABLES where TABLE_SCHEMA=\'" +databaseName +
"\' and TABLE_NAME=\'" + tableName + "\'";
try {
stmt = (Statement) conn.createStatement();
resultSet = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return resultSet;
}
List<String> loadSql(String sqlFile) throws Exception {
List<String> sqlList = new ArrayList<String>();
try {
InputStream sqlFileIn = new FileInputStream(sqlFile);
StringBuffer sqlSb = new StringBuffer();
byte[] buff = new byte[1024];
int byteRead = 0;
while ((byteRead = sqlFileIn.read(buff)) != -1) {
sqlSb.append(new String(buff, 0, byteRead));
} // Windows 下换行是 \r\n, Linux 下是 \n
String[] sqlArr = sqlSb.toString().split("(;\\s*\\r\\n)(;\\s*\\n)");
for (int i = 0; i < sqlArr.length; i++) {
String sql = sqlArr[i].replaceAll("--.*", "").trim();
if (!sql.equals("")) {
sqlList.add(sql);
}
}
return sqlList;
} catch (Exception ex) {
throw new Exception(ex.getMessage());
}
}
}

102
src/step2/CreateTableTest.java
View File

@ -1,102 +0,0 @@
package step2;
import java.util.List;
import java.util.Scanner;
import java.util.logging.Logger;
import org.apache.tools.ant.Project;
import org.apache.tools.ant.taskdefs.SQLExec;
import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class CreateTableTest {
Scanner sc = new Scanner(System.in);
String tableName =sc.nextLine().trim();
int fieldNum = Integer.parseInt(sc.nextLine().trim());
String[][]TableInfo = initTableInfo(fieldNum);
int arrayIndex=0;
String fieldName="";
String prop="";
while(true)
{
String input = sc.nextLine();
if(input.equals(""))
break;
String[]info = input.split(" ");
if(info.length != 2)
{
break;
}
//字段名
fieldName = info[0];
prop = info[1];
TableInfo[arrayIndex][0] = fieldName;
TableInfo[arrayIndex][1] = prop;
arrayIndex = arrayIndex + 1;
if(arrayIndex > fieldNum-1)
break;
}
CreateTable createTable = new CreateTable();
/*
* 执行初始化脚本（F:\test.sql）
* 执行初始化脚连接数据库时不需要指定数据库
*/
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge2.sql";
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(createTable.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(createTable.USER);
sqlExec.setPassword(createTable.PASS);
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
//将连接定位到bookStore数据库
Connection connection = createTable.getConnection(createTable.JDBC_DRIVER, createTable.DB_URL, createTable.USER, createTable.PASS);
createTable.createTable(connection, tableName,TableInfo);
//再次查询数据库，检查是否成功创建指定的表
ResultSet result = createTable.getExistTable(connection,"bookStore",tableName);
while(result.next())
{
String table = result.getString("TABLE_NAME");
System.out.print("table:"+table);
}
}
public static String[][] initTableInfo(int rowNum)
{
String[][] tmp = new String[rowNum][2];
for(int i=0;i<rowNum;i++)
{
for(int j=0;j<2;j++)
tmp[i][j] = "";
}
return tmp;
}
}

115
src/step3/InsertTable.java
View File

@ -1,115 +0,0 @@
package step3;
import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
public class InsertTable {
public void InsertRecord(Connection connection, int id, String title, String author, String publisher, int year){
//在此添加插入数据的操作
Statement stmt = null;
String sqlScript = "Insert into book(id,title,author,publisher,publishYear) values" + "(" + id +"," +
"\'" + title+ "\',\'" + author + "\',\'" + publisher + "\',\'" + year + "\')";
try {
stmt = connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
public ResultSet queryDB(Connection connection,String tableName) {
ResultSet result = null;
Statement stmt = null;
String sqlScript = "select * from " + tableName + " order by id desc";
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "";
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
List<String> loadSql(String sqlFile) throws Exception {
List sqlList = new ArrayList();
try {
InputStream sqlFileIn = new FileInputStream(sqlFile);
StringBuffer sqlSb = new StringBuffer();
byte[] buff = new byte[1024];
int byteRead = 0;
while ((byteRead = sqlFileIn.read(buff)) != -1) {
sqlSb.append(new String(buff, 0, byteRead));
} // Windows 下换行是 \r\n, Linux 下是 \n
String[] sqlArr = sqlSb.toString().split("(;\\s*\\r\\n)(;\\s*\\n)");
for (int i = 0; i < sqlArr.length; i++) {
String sql = sqlArr[i].replaceAll("--.*", "").trim();
if (!sql.equals("")) {
sqlList.add(sql);
}
}
return sqlList;
} catch (Exception ex) {
throw new Exception(ex.getMessage());
}
}
}

77
src/step3/InsertTableTest.java
View File

@ -1,77 +0,0 @@
package step3;
import java.util.List;
import java.util.Scanner;
import java.awt.print.Printable;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
import org.apache.tools.ant.*;
import org.apache.tools.ant.taskdefs.*;
import org.apache.tools.ant.taskdefs.condition.Equals;
import org.apache.tools.ant.types.*;
public class InsertTableTest {
public static void main(String[] args) throws Exception {
String tableName = "book";
InsertTable insertTable = new InsertTable();
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge3.sql";
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(insertTable.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(insertTable.USER);
sqlExec.setPassword(insertTable.PASS);
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
Connection connection = insertTable.getConnection(insertTable.JDBC_DRIVER, insertTable.DB_URL, insertTable.USER, insertTable.PASS);
Scanner sc = new Scanner(System.in);
while(true)
{
String input = sc.nextLine();
if(input.equals(""))
break;
String[]commands = input.split(" ");
if(commands.length ==0)
break;
int id = Integer.parseInt(commands[0]);
String title = commands[1];
String author = commands[2];
String publisher = commands[3];
int year = Integer.parseInt(commands[4]);
insertTable.InsertRecord(connection, id,title,author,publisher,year);
}
ResultSet result = insertTable.queryDB(connection, tableName);
while (result.next()) {
String id = result.getString("id");
String title= result.getString("title");
String author = result.getString("author");
String publisher = result.getString("publisher");
String publishYear = result.getString("publishYear");
System.out.println(id + " " + title+ " " + author + " "
+ publisher + " " + publishYear);
}
}
}

88
src/step4/DeleteRecord.java
View File

@ -1,88 +0,0 @@
package step4;
import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class DeleteRecord {
public int deleteRecordByAuthor(Connection connection, String tableName,String author)
{
Statement stmt = null;
int updatedNum = 0;
//请在此处添加数据库删除记录的实现代码
String sqlScript = "delete from " + tableName + " where author = \'" + author + "\'";
try {
stmt = connection.createStatement();
updatedNum = stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return updatedNum;
}
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "";
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
public ResultSet queryDB(Connection connection,String tableName) {
ResultSet result = null;
Statement stmt = null;
String sqlScript = "select * from " + tableName + " order by id desc";
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
}

67
src/step4/DeleteRecordTest.java
View File

@ -1,67 +0,0 @@
package step4;
import java.util.Scanner;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
import org.apache.tools.ant.*;
import org.apache.tools.ant.taskdefs.*;
import org.apache.tools.ant.types.*;
public class DeleteRecordTest {
public static void main(String[] args) throws SQLException {
String tableName ="book";
String authorName = "";
Scanner sc = new Scanner(System.in);
authorName = sc.nextLine();
DeleteRecord deleteTable = new DeleteRecord();
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(deleteTable.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(deleteTable.USER);
sqlExec.setPassword(deleteTable.PASS);
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge4.sql";
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
Connection connection = deleteTable.getConnection(deleteTable.JDBC_DRIVER, deleteTable.DB_URL, deleteTable.USER, deleteTable.PASS);
int updatedNum = deleteTable.deleteRecordByAuthor(connection,tableName,authorName);
//updatedNum=0说明删除的行数为0，删除失败
if(updatedNum == 0)
{
System.out.println(0);
return;
}
ResultSet result = deleteTable.queryDB(connection, tableName);
while (result.next()) {
String id = result.getString("id");
String title= result.getString("title");
String author = result.getString("author");
String publisher = result.getString("publisher");
String publishYear = result.getString("publishYear");
System.out.println(id + " " + title+ " " + author + " "
+ publisher + " " + publishYear);
}
}
}

70
src/step5/QueryRecord.java
View File

@ -1,70 +0,0 @@
package step5;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class QueryRecord {
public ResultSet queryPublisherByBookName(Connection connection, String tableName,String bookName)
{
//请在此处查询表的操作
Statement stmt = null;
ResultSet result = null;
String sqlScript = "select distinct(publisher) from " + tableName + " where title = '" + bookName + "\'";
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "";
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
}

54
src/step5/QueryRecordTest.java
View File

@ -1,54 +0,0 @@
package step5;
import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.*;
import org.apache.tools.ant.Project;
import org.apache.tools.ant.taskdefs.SQLExec;
public class QueryRecordTest {
public static void main(String[] args) throws SQLException {
String tableName = "book";
String bookName = "";
Scanner scanner = new Scanner(System.in);
String input = scanner.nextLine();
String[] queryInfo = input.split(" ");
if(queryInfo.length != 1)
{
System.out.println("参数输入错误");
return;
}
bookName = queryInfo[0];
QueryRecord queryRecord = new QueryRecord();
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge4.sql";
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(queryRecord.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(queryRecord.USER);
sqlExec.setPassword(queryRecord.PASS);
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
Connection connection = queryRecord.getConnection(queryRecord.JDBC_DRIVER, queryRecord.DB_URL, queryRecord.USER, queryRecord.PASS);
ResultSet result = queryRecord.queryPublisherByBookName(connection, tableName,bookName);
while(result.next())
{
String id = result.getString("publisher");
System.out.println("publisher:" + id);
}
}
}

86
src/step6/UpdateRecord.java
View File

@ -1,86 +0,0 @@
package step6;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
import org.apache.tools.ant.*;
import org.apache.tools.ant.taskdefs.*;
import org.apache.tools.ant.types.*;
public class UpdateRecord {
public int updatePublisherByTitle(Connection connection,String tableName, String title, String publisher){
//请在此处实现数据更新功能
Statement stmt = null;
int updatedNum=0;
String sqlScript = "update " + tableName + " set publisher=\'" +publisher + "\' where title=\'" + title + "'";
try {
stmt = connection.createStatement();
updatedNum = stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return updatedNum;
}
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "";
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
public ResultSet queryDB(Connection connection,String tableName) {
ResultSet result = null;
Statement stmt = null;
String sqlScript = "select * from " + tableName + " order by id desc";
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
}

69
src/step6/UpdateRecordTest.java
View File

@ -1,69 +0,0 @@
package step6;
import java.util.Scanner;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.io.*;
import org.apache.tools.ant.*;
import org.apache.tools.ant.taskdefs.*;
import org.apache.tools.ant.types.*;
public class UpdateRecordTest {
public static void main(String args[]) throws SQLException {
String tableName = "book";
UpdateRecord updateRecord = new UpdateRecord();
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge6.sql";
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(updateRecord.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(updateRecord.USER);
sqlExec.setPassword(updateRecord.PASS);
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
Connection connection = updateRecord.getConnection(updateRecord.JDBC_DRIVER, updateRecord.DB_URL, updateRecord.USER, updateRecord.PASS);
Scanner scanner = new Scanner(System.in);
while(true)
{
String input = scanner.nextLine();
if(input.equals(""))
break;
String[]commands = input.split(" ");
if(commands.length ==0 || commands.length != 2)
break;
String title = commands[0];
String publisher = commands[1];
int updatedNum = updateRecord.updatePublisherByTitle(connection, tableName,title,publisher);
}
ResultSet result = updateRecord.queryDB(connection, tableName);
while (result.next()) {
String id = result.getString("id");
String title= result.getString("title");
String author = result.getString("author");
String publisher = result.getString("publisher");
String publishYear = result.getString("publishYear");
System.out.println(id + " " + title+ " " + author + " "
+ publisher + " " + publishYear);
}
}
}

125
src/step7/TransferTable.java
View File

@ -1,125 +0,0 @@
package step7;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import javax.naming.spi.DirStateFactory.Result;
public class TransferTable {
public void transferTable(Connection connection, String tableName) throws SQLException{
//请在此将转换表结构的函数补充完整。
ResultSet result = null;
Statement stmt = null;
String sqlScript = "select * from " + tableName + " order by id desc";
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
String sqlScrript = "insert into transformedBook (id,column_name,value) values (";
while (result.next()) {
String sql = "";
String id = result.getString("id");
String title= result.getString("title");
if(title != null)
{
sql = sqlScript + id + ",'" + "title" + "','" + title + "');";
InsertRecord(connection, sql);
}
String author = result.getString("author");
if(author != null)
{
sql = sqlScript + id + ",'" + "author" + "','" + author + "');";
InsertRecord(connection, sql);
}
String publisher = result.getString("publisher");
if(publisher != null)
{
sql = sqlScript + id + ",'" + "publisher" + "','" + publisher + "');";
InsertRecord(connection, sql);
}
String publishYear = result.getString("publishYear");
if(publishYear != null)
{
sql = sqlScript + id + ",'" + "publishYear" + "','" + publishYear + "');";
InsertRecord(connection, sql);
}
}
}
public void InsertRecord(Connection connection,String sqlScript){
Statement stmt = null;
try {
stmt = connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
public ResultSet queryDB(Connection connection, String tableName){
//请在此处查询表的操作
Statement stmt = null;
ResultSet result = null;
String sqlScript = "select * from " + tableName;
try {
stmt = connection.createStatement();
result = stmt.executeQuery(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
// 设定JDBC驱动以及本地数据库的URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql:///bookstore?useUnicode=true&characterEncoding=utf-8";
// 指定数据库的用户名和密码
static final String USER = "root";
static final String PASS = "123123";
// 建立与指定数据库的连接，并返回该连接
public Connection getConnection(String jdbc_driver, String db_url, String db_user, String db_passwd) {
Connection connection = null;
//注册JDBC驱动
try {
Class.forName(jdbc_driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
//创建于指定数据库的连接
try {
connection = (Connection) DriverManager.getConnection(db_url, db_user, db_passwd);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
//创建数据库实例
public void createDatabaseInstance(Connection connection, String databaseName){
Statement stmt = null;
//请在此处补全创建数据库实例的SQL语句
String sqlScript = "";
try {
stmt = (Statement) connection.createStatement();
stmt.executeUpdate(sqlScript);
} catch (SQLException e) {
e.printStackTrace();
}
}
}

63
src/step7/TransferTableTest.java
View File

@ -1,63 +0,0 @@
package step7;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;
import java.io.*;
import org.apache.tools.ant.*;
import org.apache.tools.ant.taskdefs.*;
import org.apache.tools.ant.types.*;
public class TransferTableTest {
public static void main(String args[]) throws SQLException {
TransferTable transferTable = new TransferTable();
//原始的表名
String tableName = "book";
//转换后的表名
String transferTableName = "transformedBook";
//获取初始化的sql脚本
String sqlFile=System.getProperty("user.dir")+File.separator+"challenge7.sql";
SQLExec sqlExec = new SQLExec();
//设置数据库参数
sqlExec.setDriver(transferTable.JDBC_DRIVER);
sqlExec.setUrl("jdbc:mysql://localhost/");
sqlExec.setUserid(transferTable.USER);
sqlExec.setPassword(transferTable.PASS);
try
{
//要执行的脚本
sqlExec.setSrc(new File(sqlFile));
sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
sqlExec.execute();
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
Connection connection = transferTable.getConnection(transferTable.JDBC_DRIVER, transferTable.DB_URL, transferTable.USER, transferTable.PASS);
transferTable.transferTable(connection, tableName);
//查询数据库中转换后的表，输出其内容以判断操作转换操作是否正确
ResultSet resultSet = transferTable.queryDB(connection, transferTableName);
while(resultSet.next())
{
String id = resultSet.getString("id");
String columnName = resultSet.getString("columnName");
String value = resultSet.getString("value");
//注意这里每行后有换行，即最后一行后有换行。
System.out.println(id + " " + columnName + " " + value);
}
}
}

0
src/target/readme.txt
View File

38
src/test/java/test/test/AppTest.java Normal file
View File

@ -0,0 +1,38 @@
package test.test;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
/**
* Unit test for simple App.
*/
public class AppTest
extends TestCase
{
/**
* Create the test case
*
* @param testName name of the test case
*/
public AppTest( String testName )
{
super( testName );
}
/**
* @return the suite of tests being tested
*/
public static Test suite()
{
return new TestSuite( AppTest.class );
}
/**
* Rigourous Test :-)
*/
public void testApp()
{
assertTrue( true );
}
}

5
target/classes/META-INF/MANIFEST.MF Normal file
View File

@ -0,0 +1,5 @@
Manifest-Version: 1.0
Built-By: kevin
Build-Jdk: 1.8.0_101
Created-By: Maven Integration for Eclipse

7
target/classes/META-INF/maven/test/test/pom.properties Normal file
View File

@ -0,0 +1,7 @@
#Generated by Maven Integration for Eclipse
#Wed Sep 20 07:09:35 CST 2017
version=0.0.1-SNAPSHOT
groupId=test
m2e.projectName=test
m2e.projectLocation=C\:\\software\\Code\\dockerAPI\\tmp
artifactId=test

46
target/classes/META-INF/maven/test/test/pom.xml Normal file
View File

@ -0,0 +1,46 @@
<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>test</groupId>
<artifactId>test</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>test</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<!-- https://mvnrepository.com/artifact/io.fabric8/kubernetes-client -->
<dependency>
<groupId>io.fabric8</groupId>
<artifactId>kubernetes-client</artifactId>
<version>2.6.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.spotify/docker-client -->
<dependency>
<groupId>com.spotify</groupId>
<artifactId>docker-client</artifactId>
<version>8.9.0</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.github.docker-java/docker-java -->
<dependency>
<groupId>com.github.docker-java</groupId>
<artifactId>docker-java</artifactId>
<version>3.0.13</version>
</dependency>
</dependencies>
</project>

BIN
target/classes/test/test/App$1.class Normal file
View File

Binary file not shown.

BIN
target/classes/test/test/App.class Normal file
View File

Binary file not shown.

BIN
target/classes/test/test/DockerApiTest.class Normal file
View File

Binary file not shown.

BIN
target/classes/test/test/DockerJava$1.class Normal file
View File

Binary file not shown.

BIN
target/classes/test/test/DockerJava.class Normal file
View File

Binary file not shown.

0
target/readme.txt
View File

BIN
target/test-classes/test/test/AppTest.class Normal file
View File

Binary file not shown.