package com.naver.cafe.familyyd.minemung.MysqlExample;

import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;

import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.plugin.java.JavaPlugin;


public class PluginMain extends JavaPlugin  {

	final String DB_USERNAME = "사용자 이름";
	final String DB_PASSWORD = "비밀번호";
	final String DB_URL = "jdbc:mysql://서버주소(도메인 또는 IP 주소):포트/데이터베이스 이름";

	private void msg(CommandSender sender, String format, Object... args)
	{
		sender.sendMessage(String.format(format, args));
	}

	@Override
	public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args)
	{
		try
		{
			Connection con = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD);
			Statement st = con.createStatement();

			if (st.execute(String.join(" ", args)))
			{
				ResultSet result = st.getResultSet();
				ResultSetMetaData meta = result.getMetaData();

				long index = 1;
				int colcnt = meta.getColumnCount();

				while (result.next())
				{
					msg(sender, "================================ %d번째 행", index++);

					for (int col = 1; col <= colcnt; col++)
					{
						msg(sender, "%s (%s): %s", meta.getColumnName(col), meta.getColumnTypeName(col), result.getObject(col).toString());
					}
				}

				if (!result.isClosed()) result.close();
			}
			else
			{
				msg(sender, "총 %d개 행 반영됨.", st.getUpdateCount());
			}

			if (!con.isClosed()) con.close();
		}
		catch (Exception e)
		{
			ByteArrayOutputStream os = new ByteArrayOutputStream();
			e.printStackTrace(new PrintStream(os));
			msg(sender, new String(os.toByteArray()));
		}

		return true;
	}
}