使用java在mysql中存储来自流api的tweet

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class MySQLConnector {
    private static final String DB_URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String DB_USER = "username";
    private static final String DB_PASSWORD = "password";

    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
    }
}

import twitter4j.*;
import twitter4j.conf.ConfigurationBuilder;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TweetStreamer {
    public static void main(String[] args) throws TwitterException, SQLException {
        ConfigurationBuilder cb = new ConfigurationBuilder();
        cb.setDebugEnabled(true)
                .setOAuthConsumerKey("consumerKey")
                .setOAuthConsumerSecret("consumerSecret")
                .setOAuthAccessToken("accessToken")
                .setOAuthAccessTokenSecret("accessTokenSecret");

        TwitterStream twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
        StatusListener listener = new StatusListener() {
            public void onStatus(Status status) {
                try {
                    saveTweetToDatabase(status);
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {}

            public void onTrackLimitationNotice(int numberOfLimitedStatuses) {}

            public void onException(Exception ex) {
                ex.printStackTrace();
            }

            // Other overridden methods...
        };

        twitterStream.addListener(listener);
        twitterStream.sample();
    }

    private static void saveTweetToDatabase(Status status) throws SQLException {
        Connection connection = MySQLConnector.getConnection();
        String query = "INSERT INTO tweets (tweet_id, user_id, text) VALUES (?, ?, ?)";
        PreparedStatement statement = connection.prepareStatement(query);
        statement.setLong(1, status.getId());
        statement.setLong(2, status.getUser().getId());
        statement.setString(3, status.getText());
        statement.executeUpdate();
        statement.close();
        connection.close();
    }
}

CREATE TABLE tweets (
    tweet_id BIGINT PRIMARY KEY,
    user_id BIGINT,
    text VARCHAR(255)
);