java連接postgresql數(shù)據(jù)庫(kù)代碼及maven配置方式

第java連接postgresql數(shù)據(jù)庫(kù)代碼及maven配置方式目錄java連接postgresql代碼及maven配置maven依賴(lài)Springboo連接數(shù)據(jù)庫(kù)通用代碼創(chuàng)建連接并執(zhí)行業(yè)務(wù)邏輯數(shù)據(jù)庫(kù)通用類(lèi)maven配置

java連接postgresql代碼及maven配置

postgresql數(shù)據(jù)庫(kù)有默認(rèn)數(shù)據(jù)庫(kù)用戶(hù)postgres，密碼安裝庫(kù)時(shí)自己輸入；

當(dāng)然也可以連接其他用戶(hù)；

maven依賴(lài)

db2依賴(lài)

dependency

groupIdmons/groupId

artifactIdcommons-dbcp2/artifactId

scopeprovided/scope

/dependency

連接postgresql的依賴(lài)

dependency

groupIdpostgresql/groupId

artifactIdpostgresql/artifactId

version8.2-504.jdbc3/version

/dependency

Oracle

dependency

groupIdcom.oracle/groupId

artifactIdojdbc14/artifactId

version.0/version

/dependency

MySQL

dependency

groupIdmysql/groupId

artifactIdmysql-connector-java/artifactId

version5.0.5/version

/dependency

QLServer

dependency

groupIdnet.sourceforge.jtds/groupId

artifactIdjtds/artifactId

version1.2/version

/dependency

java代碼：

packagecom.weimanage.data;

importmons.dbcp2.BasicDataSourceFactory;

importorg.springframework.context.annotation.Bean;

importjavax.sql.DataSource;

importjava.util.Properties;

publicclassgetDataSource{

@Bean(name="dataSource")

publicstaticDataSourcegetDataSource(){

Propertiesprops=newProperties();

props.setProperty("driver","org.postgresql.Driver");

props.setProperty("url","jdbc:postgresql://:5432/postgres");

props.setProperty("user","postgres");

props.setProperty("password","1");

DataSourcedataSource=null;

try{

dataSource=BasicDataSourceFactory.createDataSource(props);

}catch(Exceptione){

e.printStackTrace();

}

returndataSource;

}

}

Springboo連接數(shù)據(jù)庫(kù)通用代碼

創(chuàng)建連接并執(zhí)行業(yè)務(wù)邏輯

packagecom.hui.xiaoqiang;

importorg.slf4j.Logger;

importorg.slf4j.LoggerFactory;

importorg.springframework.scheduling.annotation.Scheduled;

importorg.springframework.stereotype.Component;

importjava.sql.Connection;

importjava.sql.ResultSet;

importjava.sql.SQLException;

@Component

publicclassScheduledTask{

privatestaticfinalLoggerlogger=LoggerFactory.getLogger(ScheduledTask.class);

@Scheduled(cron="*/10****")//每10秒鐘執(zhí)行一次

privatevoidprocess()throwsSQLException{

("開(kāi)始--

try{

Connectionconn_gauss=GaussUttils.getConnection("heheda","123456");

//二級(jí)頁(yè)面出數(shù)語(yǔ)句

GaussUttils.executeFileSqls(conn_gauss);

ResultSetduowei=GaussUttils.getset_dwfxhz(conn_gauss);

while(duowei.next()){

System.out.println("1---

}

//關(guān)閉數(shù)據(jù)庫(kù)連接。

conn_gauss.close();

}catch(Exceptione){

e.printStackTrace();

}

("結(jié)束--

}

}

數(shù)據(jù)庫(kù)通用類(lèi)

packagecom.hui.xiaoqiang;

importorg.slf4j.Logger;

importorg.slf4j.LoggerFactory;

importjava.sql.*;

publicclassConnectionUtil{

privatestaticfinalLoggerlogger=LoggerFactory.getLogger(ConnectionUtil.class);

//創(chuàng)建數(shù)據(jù)庫(kù)連接。

publicstaticConnectiongetConnection(Stringusername,Stringpasswd){

//oracle

Stringdriver="oracle.jdbc.driver.OracleDriver";

StringsourceURL="jdbc:oracle:thin:@//10:1521/xiaoqiang";

//sqlserver

//Stringdriver="com.microsoft.sqlserver.jdbc.SQLServerDriver";

//StringsourceURL="jdbc:sqlserver://10:1433;DatabaseName=小強(qiáng)簽名設(shè)計(jì)";

//GaussDB

//Stringdriver="org.postgresql.Driver";

//StringsourceURL="jdbc:postgresql://10:25308/db_heheda";

Connectionconn;

try{

//加載數(shù)據(jù)庫(kù)驅(qū)動(dòng)。

Class.forName(driver).newInstance();

}catch(Exceptione){

e.printStackTrace();

returnnull;

}

try{

//創(chuàng)建數(shù)據(jù)庫(kù)連接。

conn=DriverManager.getConnection(sourceURL,username,passwd);

System.out.println("Connectiongausssucceed!");

}catch(Exceptione){

e.printStackTrace();

returnnull;

}

returnconn;

};

publicstaticResultSetgetset_dwfxhz(Connectionconn){

Stringsql="SELECT*FROMxiaoqiang.gr_jswhereROWNUM//oracle

ResultSetset=null;

try{

Statementstmt=null;

stmt=conn.createStatement();

set=stmt.executeQuery(sql);

}catch(SQLExceptione){

e.printStackTrace();

}

returnset;

}

//執(zhí)行文件中的SQL語(yǔ)句

publicstaticvoidexecuteFileSqls(Connectionconn){

Statementstmt=null;

try{

stmt=conn.createStatement();

String[]flieSqls=getSqls("heheda.sql");//把該文件放到resources目錄下即可，注意文件命名不要用中文

for(inti=0;iflieSqls.length;i++){

try{

stmt.execute(flieSqls[i]);

}catch(SQLExceptione){

e.printStackTrace();

System.out.println("該語(yǔ)句有問(wèn)題，請(qǐng)排查--"+flieSqls[i]);

}

}

stmt.close();

}catch(SQLExceptione){

if(stmt!=null){

try{

stmt.close();

}catch(SQLExceptione1){

e1.printStackTrace();

}

}

e.printStackTrace();

}

}

publicstaticString[]getSqls(Stringfilename){

try{

InputStreamio=Thread.currentThread().getContextClassLoader().getResourceAsStream(filename);

InputStreamReaderisr=newInputStreamReader(io,"utf-8");

BufferedReaderbr=newBufferedReader(isr);

Stringline;

StringBuildergaussqls=newStringBuilder();

while((line=br.readLine())!=null){

if(!line.contains("--")){//把注釋行去掉

gaussqls.append(line);

gaussqls.append("");//解決拼接的兩行中間可能沒(méi)有空格的問(wèn)題

}

}

String[]sqls=gaussqls.toString().split(";");

br.close();

returnsqls;

}catch(Exceptione){

e.printStackTrace();

returnnull;

}

}

}

maven配置

!--oracle--

dependency

groupIdcom.or