package com.zyna.db;
import java.sql.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import sun.applet.Main;
/**
*
* @author Administrator
*/
public class DbAccessor {
private Connection conn;
private Statement stmt;
//boco server posgresql
private String hostIp="10.0.3.40";
//local
//private String hostIp="localhost";
private String port="5432";
private String dbName="smp_main";
//server
private String dbAdmin="smp";
//private String dbAdmin="postgres";
//
//boco server posgresql
private String dbPassword="smpboco";
//local
// private String dbPassword="orcl";
// Class.forName("org.postgresql.Driver").newInstance();
// String url ="jdbc:postgresql://localhost/myDB"
// //myDB为数据库名
// String user="myuser";
// String password="mypassword";
// Connection conn= DriverManager.getConnection(url,user,password);
// 请给我个完整的代码,我在数据库里建了一个库叫harddisk,
//
private void getConnection() {
try {
// TODO code application logic here
//加载驱动
//Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
//Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
Class.forName("org.postgresql.Driver");
try {
//连接数据库
// conn = DriverManager.getConnection("jdbc:sqlserver://" + hostIp + ":"
// + port + ";databaseName=" + dbName, dbAdmin, dbPassword);
String str = "jdbc:postgresql://" + hostIp + ":"+ port + ";databaseName=" + dbName;
System.out.println("str-->"+str);
conn = DriverManager.getConnection("jdbc:postgresql://" + hostIp + ":"+ port + "/" + dbName, dbAdmin, dbPassword);
} catch (SQLException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("数据库连接失败!!");
}
} catch (ClassNotFoundException ex) {
Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
System.out.println("数据库驱动程序加载失败!");
}
}
public ResultSet execute(String sql){
try{
if(conn==null){
getConnection();
}
//创建Statement对象
stmt = conn.createStatement();
try {
//将SQL字符串送给Statement执行
ResultSet rs;
//如果SQL语句是SELECT语句
if(sql.substring(0, 6).equalsIgnoreCase("select")){
rs= stmt.executeQuery(sql);
return rs;
} else{
stmt.executeUpdate(sql);
return null;
}
} catch (SQLException ex) {
System.out.println("SQL语句执行错误!!!");
System.out.println(sql);
}
} catch (SQLException ex) {
System.out.println("创建Statement失败!!");
}
return null;
}
public void close() {
try {
stmt.close();
conn.close();
} catch (SQLException ex) {
Logger.getLogger(DbAccessor.class.getName()).log(Level.SEVERE, null, ex);
}
}
public static void main(String[] args){
DbAccessor dbAccessor = new DbAccessor();
dbAccessor.getConnection();
}
}
分享到:
相关推荐
asp连接postgresql数据库 的源码
JDBC 连接到 PostgreSQL 数据库获取数据简单例子,最小的代码实现数据库读取
MyBatis通过 JDBC连接 Mysql数据库 最小例子,没有加载多余的库
C#连接PostgreSQL数据库的驱动:Mono.Security.dll、Npgsql.dll
JDBC 连接到 PostgreSQL 数据库简单例子,最简单的代码实现
个人完整的源码安装步骤,希望对你有用。亲测可用。Centos6.2下以JDBC驱动连接任意数据库实现读操作
连接postgresql数据库的java代码
使用Druid数据连接池连接PostgreSQL简单例子,搭建一个简单测试环境
C# 操作PostgreSQL 数据库 .
DBeaver工具再连接数据库 postgresql 时需要的驱动 jar 包,7z 包里面有多个jar,解压后直接在DBeaver的菜单 数据库》驱动管理器》编辑驱动‘postgresql’ 面板添加该文件夹即可
ASP.Net2.0连接PostgreSQL数据库(C#).txt
1.nacos服务,适配postgresql数据库。 2.提供nacos,postgresql的创建nacos数据库脚本。 3.nacos/conf/nacos-pg.sql数据库脚本文件。 4.nacos版本1.4.2。
postgresql数据库连接jar包
Jdbc连接postgresql数据库,其中包含源码和jar文件
C#连接数据库MYSQL和POSTGRESQL.pdf
本文档主要讲解ubuntu下QT连接数据库的时出现的各种驱动加载错误的问题的解决方法
6个dll的打包 Arcgis连接 postgresql sde 时遇到的问题以及解决办法 Arcgis连接 postgresql sde 时遇到的问题以及解决办法
Matlab与PostgreSQL数据库的连接方法,亲测可用