sol.java

JDBC连Oracle数据库。 适合初学者

package com;

import java.awt.Container;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;

public class sol extends JFrame {

	// static final String SQLServer_DRIVER =
	// "com.microsoft.jdbc.sqlserver.SQLServerDriver";
	//
	// static final String SQLServer_URL =
	// "jdbc:microsoft:sqlserver://192.168.0.115:1433;DatabaseName=config";
	//
	// static final String SQLServer_USER = "sa";
	//
	// static final String SQLServer_PWD = "sa";
	//
	// static final String SQLServer_QUERY = "select * from cofig1";
	static final String SQLServer_DRIVER = "oracle.jdbc.driver.OracleDriver";

	static final String SQLServer_URL = "jdbc:oracle:thin:@127.0.0.1:1521:DF";

	static final String SQLServer_USER = "scott";

	static final String SQLServer_PWD = "tiger";

	static final String SQLServer_QUERY = "select * from emp";

	private Connection connection;

	private Statement statement;

	public sol() {
		super("Oracle Connection Tester");
		try {
			Class.forName(SQLServer_DRIVER);// 加载数据库驱动程序
			connection = DriverManager.getConnection(SQLServer_URL,
					SQLServer_USER, SQLServer_PWD);
			// 方法getConnection 返回一个连接对象
			statement = connection.createStatement();

			StringBuffer results = new StringBuffer();
			ResultSet resultSet = statement.executeQuery(SQLServer_QUERY);
			ResultSetMetaData metaData = resultSet.getMetaData();
			int numberOfColumns = metaData.getColumnCount();
			for (int i = 1; i <= numberOfColumns; i++) {
				// 测试类的名称及其列在数据库中的类型
				System.out.print("ColumnName=" + metaData.getColumnName(i));
				System.out.println("  " + metaData.getColumnTypeName(i));
				results.append(metaData.getColumnName(i) + "\t");
				// 注意字符串表示的相等方式
				if (metaData.getColumnName(i).equals("address")) {
					results.append("\t");
				}
			}
			System.out.println();
			results.append("\n");

			while (resultSet.next()) {
				for (int i = 1; i <= numberOfColumns; i++) {
					results.append(resultSet.getObject(i) + "\t");
					// 测试jdbc的数据类型，注意结果集取对象为空的情况！
					if (resultSet.getObject(i) != null)
						System.out.println(""
								+ resultSet.getObject(i).getClass());
				}
				System.out.println("\n");
				results.append("\n");
			}

			Container container = getContentPane();
			JTextArea textArea = new JTextArea(results.toString());
			container.add(new JScrollPane(textArea));

			setSize(800, 350);
			setVisible(true);

			// 如果不能有效地加载驱动，JFrame 中的组件部分将不必要显示
		} catch (ClassNotFoundException classNotFound) {
			JOptionPane.showMessageDialog(null, classNotFound.getMessage(),
					"Drier Not Found", JOptionPane.ERROR_MESSAGE);
			System.exit(1);
		} catch (SQLException sqlException) {
			JOptionPane.showMessageDialog(null, sqlException.getMessage(),
					"Database Error", JOptionPane.ERROR_MESSAGE);
			System.exit(1);
		} finally {

			try {
				statement.close();
				connection.close();
			} catch (SQLException sqlException) {
				JOptionPane.showMessageDialog(null, sqlException.getMessage(),
						"Database Error", JOptionPane.ERROR_MESSAGE);
				System.exit(1);
			}
		}
	}

	public static void main(String[] args) {
		sol window = new sol();
		window.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
	}

}