GINPRO / SQLの窓と銀プログラマ

import java.util.ArrayList;
import java.util.ListIterator;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;


public class Main {

	// Livedoor の お天気Webサービス用 (JSON用)
	class Weather {
		// ArrayList で定義
		ArrayList<PinpointLocation> pinpointLocations;
	}
	class Weather2 {
		// 配列で定義
		PinpointLocation[] pinpointLocations;
	}

	public static void main(String[] args) {
		// TODO 自動生成されたメソッド・スタブ

		System.out.println("開始");

		// データをセット
		String result = Tools.httpGet(
			"http://weather.livedoor.com/forecast/webservice/json/v1?city=270000",
			"utf-8",
			null
		);

		System.out.println(result);

		Gson gson = new Gson();

		// ArrayList として処理
		Weather weatherData = gson.fromJson(result, Weather.class);

		// 多いので40番目から
		ListIterator<PinpointLocation> li = weatherData.pinpointLocations.listIterator(39);
		while(li.hasNext()) {
			PinpointLocation data = li.next();
			System.out.println(data.name + " : " + data.link );
		}

		System.out.println("-----------------------------------------");

		// 配列
		Weather2 weatherData2 = gson.fromJson(result, Weather2.class);

		// 多いので40番目から
		for( int i = 39; i < weatherData2.pinpointLocations.length; i++ ) {
			PinpointLocation data = weatherData2.pinpointLocations[i];
			System.out.println(data.name + " : " + data.link );
		}

		// 多いので40番目から( 39 番までを削除 )
		for( int i = 38; i >= 0; i-- ) {
			weatherData.pinpointLocations.remove(i);
		}
		
		Gson gsonPretty = new GsonBuilder().setPrettyPrinting().create();
		String json1 = gsonPretty.toJson(weatherData);
		System.out.println( json1 );

	}

}

Gson prettyGson = new GsonBuilder().setPrettyPrinting().create();
String json = prettyGson.toJson(weatherData);

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.Iterator;
import java.util.Map;


public class Tools {

	// 指定した URL へ 任意の charset で処理
	public static String httpGet( String targetUrl,String targetCharset,Map<String,String> params) {

		StringBuffer web_data = new StringBuffer();

		try {
			// Query String の作成( 必要無ければ引数を null とする )
			String data = "";
			if ( params != null ) {
				Iterator<String> it =  params.keySet().iterator();
				String key = null;
				String value = null;
				while(it.hasNext()) {
					key = it.next().toString();
					value = params.get(key);
					if ( !data.equals("") ) {
						data += "&";
					}
					data += key + "=" + URLEncoder.encode(value, targetCharset) ;
				}
				if ( !data.equals("") ) {
					targetUrl = targetUrl + "?" + data;
				}
			}

			// **********************************************
			// インターネットへの接続
			// **********************************************
			// 読み込む WEB上のターゲット
			URL url = new URL(targetUrl);
			// 接続オブジェクト
			HttpURLConnection http = (HttpURLConnection)url.openConnection();
			// GET メソッド
			http.setRequestMethod("GET");
			// 接続
			http.connect();

			// **********************************************
			// ストリームとして読み込む準備
			// **********************************************
			// 以下読み込み３点セット InputStream / InputStreamReader / BufferedReader
			InputStream input_stream = http.getInputStream();
			// UTF-8 でリーダーを作成
			InputStreamReader input_stream_reader = new InputStreamReader(input_stream, targetCharset);
			// 行単位で読み込む為の準備
			BufferedReader buffered_reader = new BufferedReader(input_stream_reader);

			// **********************************************
			// 行の一括読み込み
			// **********************************************
			String line_buffer = null;
			// BufferedReader は、readLine が null を返すと読み込み終了
			while ( null != (line_buffer = buffered_reader.readLine() ) ) {
				web_data.append( line_buffer );
				web_data.append( "\n" );
			}

			// **********************************************
			// 接続解除
			// **********************************************
			http.disconnect();
		}
		catch(Exception e) {
			// 失敗
			System.out.println(e.getMessage());
		}
		return web_data.toString();
	}
}

		Button btnDatabase = new Button(container, SWT.NONE);
		btnDatabase.addSelectionListener(new SelectionAdapter() {

			@Override
			public void widgetSelected(SelectionEvent ex) {

				boolean ret = true;

				Connection con = null;
				Statement stmt = null;
				ResultSet rset = null;

				String DriverName = "sun.jdbc.odbc.JdbcOdbcDriver";
				String connectionString =
						"Provider=MSDASQL" +
						";Driver={Microsoft Excel Driver (*.xls, *.xlsx, *.xlsm, *.xlsb)}" +
						";Dbq=C:\\user\\MDB\\syain.xlsx" +
						";Readonly=;";
				String Query = "";
				
				// 日本語設定用プロパティ
				Properties prop = new Properties();
				prop.put("charSet", "MS932");
				System.out.println(connectionString);

				// 接続
				try {
					Class.forName( DriverName );
					con = DriverManager.getConnection(
							"jdbc:odbc:" + connectionString,prop
					);

					stmt = con.createStatement();
				}
				catch( Exception e  ) {
					System.out.println(e.getMessage());
					ret = false;
				}
				// 接続失敗
				if ( !ret ) {
					return;
				}

				System.out.println("接続成功");
				// SQL 作成
				Query = "update 社員マスタ set 氏名 = 'java 更新' where 社員コード = '0001'";
				try {
					stmt.executeUpdate( Query );
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
					ret = false;
				}
				// 実行失敗
				if ( !ret ) {
					return;
				}

				// SQL 作成
				Query = "select * from 社員マスタ where 社員コード = '0001'";
				try {
					rset = stmt.executeQuery ( Query );
					ret = rset.next();
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
					ret = false;
				}

				// データが存在しないので処理終了
				if ( !ret ) {
					return;
				}

				System.out.println("SQL実行成功");

				try {
					System.out.println( rset.getString( "氏名" ) );
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
				}

				System.out.println("列データ取得成功");

				try {
					stmt.close();
					con.close();
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
				}

			}
		});

		Button btnDatabase = new Button(container, SWT.NONE);
		btnDatabase.addSelectionListener(new SelectionAdapter() {

			@Override
			public void widgetSelected(SelectionEvent ex) {

				boolean ret = true;

				Connection con = null;
				Statement stmt = null;
				ResultSet rset = null;

				String DriverName = "sun.jdbc.odbc.JdbcOdbcDriver";
				String connectionString =
						"Provider=MSDASQL" +
						";Driver={Microsoft Access Driver (*.mdb, *.accdb)}" +
						";Dbq=C:\\user\\MDB\\社員マスタ.accdb" + ";";

				// 日本語設定用プロパティ
				Properties prop = new Properties();
				prop.put("charSet", "MS932");
				System.out.println(connectionString);

				// 接続
				try {
					Class.forName( DriverName );
					con = DriverManager.getConnection(
							"jdbc:odbc:" + connectionString,prop
					);

					stmt = con.createStatement();
				}
				catch( Exception e  ) {
					System.out.println(e.getMessage());
					ret = false;
				}
				// 接続失敗
				if ( !ret ) {
					return;
				}

				System.out.println("接続成功");

				// SQL 作成
				String Query = "select * from 社員マスタ where 社員コード = '0001'";
				try {
					rset = stmt.executeQuery ( Query );
					ret = rset.next();
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
					ret = false;
				}

				// データが存在しないので処理終了
				if ( !ret ) {
					return;
				}

				System.out.println("SQL実行成功");

				try {
					System.out.println( rset.getString( "氏名" ) );
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
				}

				System.out.println("列データ取得成功");

				try {
					stmt.close();
					con.close();
				}
				catch( SQLException e ) {
					System.out.println(e.getMessage());
				}

			}
		});

public class Main extends JFrame {

	private JPanel contentPane;
	private JTextField syainCode;
	private JTextField syainName;
	private final Action checkAction = new CheckAction();
	private final Action cancelAction = new CancelAction();
	private JButton checkButton;
	private JButton updateButton;
	private JButton cancelButton;

	private String currentDir = null;
	private Connection con = null;
	private Statement stmt = null;
	private ResultSet rset = null;
	
	
	/**
	 * Launch the application.
	 */
	public static void main(String[] args) {
		EventQueue.invokeLater(new Runnable() {
			public void run() {
				try {
					Main frame = new Main();
					frame.setVisible(true);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		});
	}

	/**
	 * Create the frame.
	 */
	public Main() {
		addWindowListener(new WindowAdapter() {
			@Override
			public void windowActivated(WindowEvent arg0) {
				Main.this.setLocationRelativeTo(null);
				
				currentDir = System.getProperty("user.dir");
				System.out.println(currentDir);
			}
		});
		setResizable(false);
		setTitle("\u793E\u54E1\u30DE\u30B9\u30BF\u30E1\u30F3\u30C6");
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		setBounds(100, 100, 450, 300);
		contentPane = new JPanel();
		contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
		setContentPane(contentPane);
		contentPane.setLayout(null);
		
		JLabel label = new JLabel("\u30B3\u30FC\u30C9");
		label.setBounds(31, 32, 50, 13);
		contentPane.add(label);
		
		JLabel label_1 = new JLabel("\u6C0F\u540D");
		label_1.setBounds(31, 88, 50, 13);
		contentPane.add(label_1);
		
		syainCode = new JTextField();
		syainCode.setBounds(78, 29, 50, 19);
		contentPane.add(syainCode);
		syainCode.setColumns(10);
		
		syainName = new JTextField();
		syainName.setEnabled(false);
		syainName.setColumns(10);
		syainName.setBounds(78, 85, 202, 19);
		contentPane.add(syainName);
		
		checkButton = new JButton("\u78BA\u8A8D");
		checkButton.setAction(checkAction);
		checkButton.setBounds(304, 28, 106, 21);
		contentPane.add(checkButton);
		
		updateButton = new JButton("\u66F4\u65B0");
		updateButton.setEnabled(false);
		updateButton.setBounds(304, 170, 106, 21);
		contentPane.add(updateButton);
		
		cancelButton = new JButton("\u30AD\u30E3\u30F3\u30BB\u30EB");
		cancelButton.setAction(cancelAction);
		cancelButton.setEnabled(false);
		cancelButton.setBounds(304, 208, 106, 21);
		contentPane.add(cancelButton);
		
		
	}
	
	private class CheckAction extends AbstractAction {
		public CheckAction() {
			putValue(NAME, "確認");
			putValue(SHORT_DESCRIPTION, "Some short description");
		}
		public void actionPerformed(ActionEvent e) {
			
			// 実際は、getConnect が失敗した場合の処理が必要です
			getConnect();
			
			try {
				
				stmt = con.createStatement();
				String scode = syainCode.getText();
				rset = stmt.executeQuery ( "select * from 社員マスタ where 社員コード = '" + scode + "'" );
				if ( rset.next() ) {
					syainName.setText(rset.getString( "氏名" ));
					
					syainCode.setEnabled(false);
					checkButton.setEnabled(false);

					syainName.setEnabled(true);
					updateButton.setEnabled(true);
					cancelButton.setEnabled(true);
					
					syainName.requestFocusInWindow();
					syainName.selectAll();
					
				}
				else {
					JOptionPane.showMessageDialog(contentPane, "入力した社員コードは存在しません");
					syainCode.requestFocusInWindow();
					syainCode.selectAll();
				}
				
				rset.close();
				stmt.close();
				
			} catch (Exception e1) {
				// TODO 
				e1.printStackTrace();
			}			
			
			con.close();

		}
	}
	private class CancelAction extends AbstractAction {
		public CancelAction() {
			putValue(NAME, "キャンセル");
			putValue(SHORT_DESCRIPTION, "Some short description");
		}
		public void actionPerformed(ActionEvent e) {
			Main.this.syainCode.setEnabled(true);
			Main.this.checkButton.setEnabled(true);

			Main.this.syainName.setEnabled(false);
			Main.this.updateButton.setEnabled(false);
			Main.this.cancelButton.setEnabled(false);
			
			syainName.setText("");
		}
	}
	

	private boolean getConnect() {
		
		boolean connect_result = true;
		String connectionString = "";

		//　*********************************************
		// ODBC 用接続文字列
		//　*********************************************
		// MDB
		connectionString = "Provider=MSDASQL"
				+ ";Driver={Microsoft Access Driver (*.mdb)}"
				+ ";Dbq=" + currentDir + "\\data\\販売管理C.mdb" + ";";

		
		try {
			Properties prop = new Properties();
			prop.put("charSet", "MS932");
			System.out.println(connectionString);
			con = DriverManager.getConnection("jdbc:odbc:"+connectionString, prop);
			
		} catch (Exception e1) {
			// TODO 
			e1.printStackTrace();
			connect_result = false;
		}
		
		return connect_result;
	}
	
}