jdbc使用DataSource连接mysql,postgresql,oracle的代码

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

import org.postgresql.ds.PGSimpleDataSource;

import oracle.jdbc.pool.OracleDataSource;

import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;

public class DBConnection {

    /**
     * @param args
     * @throws SQLException
     */
    public static void main(String[] args) throws SQLException {
        // TODO Auto-generated method stub
        MysqlDataSource mysqlDataSource = new MysqlDataSource();
        // mysqlDataSource.setPassword("dev");
        // mysqlDataSource.setUser("dev");
        mysqlDataSource
                .setURL("jdbc:mysql://localhost/forJava?user=dev&password=dev");
        Connection conn = mysqlDataSource.getConnection();
        Statement stmt = conn.createStatement();
        stmt.executeUpdate("create table if not exists web\n" + "(\n"
                + "        id int not null primary key,\n" + "        name varchar(100),\n"
                + "        created timestamp,\n" + "        content blob\n" + ");\n" + "");
        for (int i = 0; i < 1; i++) {
            stmt.executeUpdate("insert into web (name,content) values ('HL','frgertrhrtnthtohioh')");
        }
        showResultSet(stmt.executeQuery("select * from web limit 10"));

        // Driver driver = new com.mysql.jdbc.Driver();
        // driver.connect("jdbc:mysql://localhost/forJava?user=dev&password=dev",
        // null);

        PGSimpleDataSource pgSimpleDataSource = new PGSimpleDataSource();
        pgSimpleDataSource.setServerName("localhost");
        pgSimpleDataSource.setDatabaseName("dev");
        pgSimpleDataSource.setUser("dev");
        pgSimpleDataSource.setPassword("dev");
        conn = pgSimpleDataSource.getConnection();
        // conn =
        // DriverManager.getConnection("jdbc:postgresql://localhost/test",
        // "dev", "dev");
        showResultSet(conn.createStatement().executeQuery("select * from cities"));

        OracleDataSource oraDataSource = new OracleDataSource();
        // oraDataSource.setServerName("127.0.0.1");
        // oraDataSource.setDatabaseName("HR");
        // oraDataSource.setUser("HR");
        // oraDataSource.setPassword("HR");
        oraDataSource.setURL("jdbc:oracle:thin:hr/hr@//localhost:1521/XE");
        conn = oraDataSource.getConnection();
        stmt = conn.createStatement();
        stmt.execute("select * from tab");
        showResultSet(stmt.getResultSet());
        stmt.execute("select * from jobs");
        showResultSet(stmt.getResultSet());
        stmt.execute("select * from DEPARTMENTS");
        showResultSet(stmt.getResultSet());
    }

    static void showResultSet(ResultSet resultSet) throws SQLException {
        ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
        int num = resultSetMetaData.getColumnCount();
        while (resultSet.next()) {
            for (int i = 1; i <= num; i++) {
                System.out.print(resultSetMetaData.getCatalogName(i) + " "
                        + resultSet.getString(i));
            }
            System.out.println();
        }
    }
}