Java连接MySQL数据库并且执行建表和插入数据

package com.resumesplice;

import java.util.*;

import java.io.*;

import java.sql.Date;

import java.text.SimpleDateFormat;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class InsertIntoStep1 {

    private static List<String> m_tableNameList = new ArrayList<String>();

    public static boolean tableExist(String tableName) {

        boolean result = false;

        try {

            Class.forName("com.mysql.jdbc.Driver");

            Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.*.**/", "***", "****");

            Statement stmt = conn.createStatement();

            String sql = String.format("SELECT table_name FROM information_schema.TABLES WHERE table_name ='%s'", tableName);

            ResultSet rs = stmt.executeQuery(sql);

            result = rs.next();

            stmt.close();

            conn.close();

        } catch (ClassNotFoundException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        return result;

    }

    public static void InsertDB(String filename, String enter_myftp_time, String process_time, String extract, String assemble, String target) {

        String currentTime = getCurrentTime();

        String tableName = "step1_" + currentTime;

        if (!m_tableNameList.contains(tableName)) {

            if (!tableExist(tableName)) {

                createtable(tableName);

            }

            m_tableNameList.add(tableName);

        }

        try {

            Class.forName("com.mysql.jdbc.Driver");

            //System.out.println("测试通过");

            Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.6.65/filemyftpprocessinfo", "root", "root");

            Statement stmt = conn.createStatement();

            String sql = "insert into " + tableName + "(filename,enter_myftp_time,process_time,extract,assemble,target) values (" + '"' + filename + '"' + " , " + '"' + enter_myftp_time + '"' + " , " + '"' + process_time + '"' + " , " + '"' + extract + '"'
+ " , " + '"' + assemble + '"' + " , " + '"' + target + '"' + " );";

            stmt.execute(sql);

            stmt.close();

            conn.close();

        } catch (ClassNotFoundException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

    public static void createtable(String tablename) {

        try {

            Class.forName("com.mysql.jdbc.Driver");

            // System.out.println("测试通过");

            Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.6.65/filemyftpprocessinfo", "root", "root");

            Statement stmt = conn.createStatement();

            String sql = "create table " + tablename + "(id int  primary key auto_increment,filename varchar(255),enter_myftp_time varchar(20),process_time varchar(20),extract varchar(1),assemble varchar(1),target varchar(255))";

            stmt.execute(sql);

            stmt.close();

            conn.close();

            

        } catch (ClassNotFoundException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

    public static void main(String[] args) {

        // TODO Auto-generated method stub

    }

    public static String getCurrentTime() {

        SimpleDateFormat df = new SimpleDateFormat("yyyyMMdd");

        return df.format(System.currentTimeMillis());

    }

}