|
package gaussdb_jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class GaussDB_jdbc {
static final String JDBC_DRIVER = "org.postgresql.Driver";
static final String DB_URL = "jdbc:postgresql://*.*.*.*:8000/java_test";
// 数据库的用户名与密码，需要根据自己的设置
static final String USER = "****";
static final String PASS = "****";
// 执行insert
public static void InsertData(Connection conn){
Statement stmt = null;
try {
stmt = conn.createStatement();
String sql;
sql = "INSERT INTO public.customer_t1(c_customer_id, c_customer_name) VALUES(1001,'张三');"
+ "INSERT INTO public.customer_t1(c_customer_id, c_customer_name) VALUES(1002,'李四');"
+ "INSERT INTO public.customer_t1(c_customer_id, c_customer_name) VALUES(1003,'王五');";
ResultSet rs = stmt.executeQuery(sql);
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 执行update
public static void UpadteData(Connection conn){
Statement stmt = null;
try {
stmt = conn.createStatement();
String sql;
sql = "UPDATE customer_t1 SET c_customer_name ='jdbc' WHERE c_customer_id =1003 ";
ResultSet rs = stmt.executeQuery(sql);
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 执行select
public static void SelectData(Connection conn){
Statement stmt = null;
try {
stmt = conn.createStatement();
String sql;
sql = "SELECT c_customer_id, c_customer_name FROM public.customer_t1";
ResultSet rs = stmt.executeQuery(sql);
// 展开结果集数据库
while(rs.next()){
// 通过字段检索
String column1 = rs.getString("c_customer_id");
String column2 = rs.getString("c_customer_name");
// 输出数据
System.out.print("c_customer_id: " + column1);
System.out.print(", c_customer_name: " + column2);
System.out.print("\n");
}
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
// 打开链接
try {
System.out.println("连接数据库...");
Connection conn = DriverManager.getConnection(DB_URL,USER,PASS);
// 执行插入数据
InsertData(conn);
//执行更新数据
UpadteData(conn);
//执行查看
SelectData(conn);
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
|
