Java连接PostGreSql

本次试验怎么用jdbc连接PostGreSql数据库。首先需要安装一个pgsql数据库，安装就不介绍了。安装后自己用SQL创建表，如有下图的库和表，怎么用java带SQL参数连接他取的数据。

PG库下载地址

首先到官网上根据自己的Java版本下载jdbc驱动jdbc下载地址

下载后把驱动投入libs

同时拷贝maven串

把maven串贴入工程

然后添加引用jar包

然后写代码操作数据库

import java.io.File;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
import java.lang.Class;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.jar.JarFile;
import java.util.jar.JarEntry;

import ZLZJar.*;

import java.sql.*;

//zlz练习
public class Main {

    //m主方法
    public static void main(String[] args) {
        try {
            //自己生成jar包路径
            URL url = new File("D:\\ZLZJar\\out\\artifacts\\ZLZJar\\ZLZJar.jar").toURI().toURL();
            URL[] urls = new URL[]{url};
            //加载程序集
            URLClassLoader loader = new URLClassLoader(urls);
            //加载类
            Class c = loader.loadClass("ZLZJar.Test");
            //创建对象
            Object o = c.newInstance();
            //得到方法
            Method m = c.getMethod("Hello");
            //执行
            m.invoke(o);
            //有参数的方法通过名称无法得到，自己包装一下
            //Method mAdd = c.getMethod("Add");
            Method mAdd = GetMethod(c, "Add");
            Object ret = mAdd.invoke(o, 1, 2);
            System.out.println("求和结果:" + ret);
            //转换成接口，这个很重要，后面的实现类都实现特定接口，通过反射得到对象调用，实现多态和动态调用
            ITest it = (ITest) o;
            //接口调用
            it.Invoke("zlz调用传入的参数");
            PgSqlTest();

        } catch (NoSuchMethodException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (InvocationTargetException e) {
            e.printStackTrace();
        }
    }

    //连接PostGreSql测试
    public static void PgSqlTest() {
        //连接串，最后的是数据库名称
        String url = "jdbc:postgresql://localhost:5432/dhclisdata";
        //用户
        String user = "postgres";
        //密码
        String password = "SYS";
        //建立连接
        Connection conn = null;
        //command
        PreparedStatement stmt = null;
        try {
            //加载驱动
            Class.forName("org.postgresql.Driver");
            conn = DriverManager.getConnection(url, user, password);

            //编译和执行SQL语句,传输SQL参数查询1997-2000行
            String sql = "SELECT * FROM dbo.SYS_Form where \"RowID\">? and \"RowID\";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1,1997);
            stmt.setInt(2,2000);
            //结果集
            ResultSet rs = stmt.executeQuery();

            // 处理查询结果
            while (rs.next()) {
                //取列数据
                int RowID = rs.getInt("RowID");
                String CName = rs.getString("CName");
                String Path = rs.getString("Path");
                //输出
                System.out.println(RowID + "\t" + CName + "\t" + Path);
            }

            // 关闭 ResultSet、Statement 和 Connection 对象
            rs.close();
        }
        catch (SQLException se) {
            // 处理 JDBC 异常
            se.printStackTrace();
        }
        catch (Exception e) {
            // 处理 Class.forName 异常
            e.printStackTrace();
        }
        finally {
            // 关闭资源
            try {
                if (stmt != null)
                {
                    stmt.close();
                }
            }
            catch (SQLException se2) {
            }
            try {
                if (conn != null)
                {
                    conn.close();
                }
            }
            catch (SQLException se2) {
            }
        }
    }

    //通过类型和名称得到方法
    public static Method GetMethod(Class c, String name) {
        Method[] methods = c.getMethods();

        for (Method method : methods) {
            System.out.println("类名:" + method.getName().intern());
            if (method.getName().intern() == name) {

                return method;

            }
        }
        return null;
    }

}

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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

操作数据库部分

//连接PostGreSql测试
    public static void PgSqlTest() {
        //连接串，最后的是数据库名称
        String url = "jdbc:postgresql://localhost:5432/dhclisdata";
        //用户
        String user = "postgres";
        //密码
        String password = "SYS";
        //建立连接
        Connection conn = null;
        //command
        PreparedStatement stmt = null;
        try {
            //加载驱动
            Class.forName("org.postgresql.Driver");
            conn = DriverManager.getConnection(url, user, password);

            //编译和执行SQL语句,传输SQL参数查询1997-2000行
            String sql = "SELECT * FROM dbo.SYS_Form where \"RowID\">? and \"RowID\";
            stmt = conn.prepareStatement(sql);
            stmt.setInt(1,1997);
            stmt.setInt(2,2000);
            //结果集
            ResultSet rs = stmt.executeQuery();

            // 处理查询结果
            while (rs.next()) {
                //取列数据
                int RowID = rs.getInt("RowID");
                String CName = rs.getString("CName");
                String Path = rs.getString("Path");
                //输出
                System.out.println(RowID + "\t" + CName + "\t" + Path);
            }

            // 关闭 ResultSet、Statement 和 Connection 对象
            rs.close();
        }
        catch (SQLException se) {
            // 处理 JDBC 异常
            se.printStackTrace();
        }
        catch (Exception e) {
            // 处理 Class.forName 异常
            e.printStackTrace();
        }
        finally {
            // 关闭资源
            try {
                if (stmt != null)
                {
                    stmt.close();
                }
            }
            catch (SQLException se2) {
            }
            try {
                if (conn != null)
                {
                    conn.close();
                }
            }
            catch (SQLException se2) {
            }
        }
    }
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

测试

jdbc操作数据库完成，第三个技术点积累完毕