postgreSQL的crud操作詳解
postgreSQL學習筆記
歡迎大家指出問題!
版本從6.0開始支援SQL直譯器
安裝一路下一步。
1.建立資料庫
//命令列操作 createdb database_name; CREATE DATABASE database_name; psql -l //展示所有資料庫 psql database_name //進入資料庫
2.刪除資料庫
dropdb database; DROP DATABASE database_name;
3.建立表
create table 表名 (title varchar(255),content text); //修改表名 alter table posts rename to 表名;
//查看錶資訊(結構) \d 表名 //執行這個sql檔案 \i a.sql //切換資料顯示方式(橫向和縱向顯示) \x
create table posts ( id serial primary key,title varchar(255) not null,content text check(length(content) > 3),is_draft boolean default FALSE,created_date timestamp default 'now');
CREATE TABLE public.students ( id integer NOT NULL,name character(128),subjects character(1),CONSTRAINT student2_pkey PRIMARY KEY (id) ) WITH ( OIDS=FALSE ); ALTER TABLE public.students OWNER TO postgres; COMMENT ON TABLE public.students IS '這是一個學生資訊表';
案例表:
4.刪除表
DROP TABLE students;
5.資料型別
數值型:
integer real serial(序列型,一般用於自增欄位)
文字型:
char varchar text
布林型:
boolean
日期型:
date time timestamp
特色型別:
Array inet(網口型別) JSON XML
6.新增表約束
unique
:所在資料中值必須唯一
check
:欄位設定條件,可以指定函式check(length(content) > 3)必須超過3個字元
default
:欄位預設值
7.INSERT語句
insert into 表名(cloum1,cloum2) value(a,b);
8.資料抽出選項:
order by asc
升序 desc
降序
limit
限制返回資料條數
offset
偏移量(從哪條資料開始)
//分頁查詢limit和offset結合使用。 select * from users order by score desc limit 3; select * from users order by score desc limit 3 offset 3;
9.統計抽出資料
distinct
去重
group by/having
(在group by
之後進行再次篩選) 分組
select team,max(score) from users group by team having max(score)>25 order by max(score);
10.方便的函式
length concat
(連線兩個字串) alias
(別名) substring
(擷取字串) random
select player,length(player) from users; select player,concat(player,"/",team) from users; select player,team) as "球員資訊" from users; select concat('我',substring(team,1,1)) as "球隊首文字" from users; //隨機抽獎 select player from users order by random() limit 1;
11.更新和刪除
update [table] set [field=newvalue,…] where … delete from [table] where …
eg:
update users set score = score + 100 where team IN ("勇士","騎士");
12.變更表結構
//alter table [tablename] … //給表新增一條fullname欄位 alter table users add fullname varchar(255);
//給哪個表的欄位建索引(索引提高查詢效率,但是增刪效果不好) create index 索引名 on users(欄位名); //刪除索引 drop index 索引名;
//修改列名 alter table users rename player to nba_player; //修改欄位的的長度 alter table users alter nba_player type varchar(128);
13.操作多個表
//兩表的關聯查詢 select users.player,twitters.content from users,twitters where users.id = twitters.user_id; //別名 select u.player,t.content from users as u,twitters as t where u.id = t.user_id;
14.使用檢視
檢視:檢視就是一個select語句,把業務系統中常用的select語句簡化成一個類似於表的物件,便於簡單讀取和開發。 (對於經常使用的select語句建立檢視便於編碼和管理)
//建立一個檢視(通過 \dv 檢視檢視描述) create view curry_twitters as select u.player,twitters as t where u.id = t.user_id; //要進行查詢時 select * from curry_twitters; //刪除檢視 drop view curry_twitters;
15.使用事務
資料庫事務:是指作為單個邏輯工作單元執行的一系列操作,要麼一起成功,要麼一起失敗。必須滿足ACID(原子性、 一致性、隔離性、永續性)
PostgreSQL
資料庫事務使用
begin
開啟事務
commit
提交
rollback
回滾
eg: begin; update users set score = 50 where player = '庫裡'; update users set score = 60 where player = '哈登'; commit; //如果不想跟新可以 rollback;
補充:postgresql一般crud儲存過程參考
這裡是一份經過再三除錯測試而成功的postgres資料庫單表crud儲存過程,請注意,對於多結果的返回方式,請檢視getPageByCondition的書寫方式,用的是refcursor,返回一個cursor,同時可以返回其他out,inout引數,但是refcursor必須在事務中呼叫,所以java端的呼叫過程需要注意,好吧,我同時放出一份dal樣板,大家可以直接copy來用。
/****************************************************************** * 表名:test3 * Made by 碼農下的天橋 ******************************************************************/ --use MYDB;--你可以指定自己的資料庫 /****************************************************************** ****************************各種常用查詢*************************** ******************************************************************/ ------------------------------------ --用途:複雜形式的查詢語句,用於查詢分頁資料。 --這個是泛用型的,假如你要根據使用者輸入去查詢,那麼最好不要用這個了, --以免出現sql注入。 --引數說明: ---_offset int 需要取的記錄的開始位置 ---_limit int 需要獲取記錄的總條數,針對分頁而言,就是分頁的pagesize。 ---_columns varchar(800) 需要獲取的欄位 ---_where varchar(800) 需要過濾的條件譬如: where id<10 可以帶where,不過建議不要帶。 ---_orderby varchar(800) 需要進行排序的提交,譬如:order by id ---_totalCount int 返回總共記錄條數。 ---_totalPages int 返回總共頁數。 ------------------------------------ create or replace function test3_getListByCondition( INOUT pageindex INT,INOUT pagesize INT,IN _columns VARCHAR(800),IN _where VARCHAR(800),IN _orderby VARCHAR(800),out _totalCount INT,out _totalPages INT) returns SETOF record AS $$ DECLARE condition_columns VARCHAR(800); DECLARE condition_where varchar(800); DECLARE condition_orderby VARCHAR(800); DECLARE _dymatic_sql VARCHAR(1600); DECLARE _beginNO INT; DECLARE _dynamic_getCount varchar(1600); DECLARE _theOffset INT; DECLARE _tmpInt1 INT; BEGIN condition_where:=ltrim(rtrim(COALESCE(_where,''))); condition_orderby:=ltrim(rtrim(COALESCE(_orderby,'order by t3id'))); condition_columns:=ltrim(rtrim(COALESCE(_columns,'*'))); --分析傳過來的引數,構造動態sql語句。 IF "character_length"(condition_where)>0 THEN IF strpos(condition_where,'where ')!=1 THEN condition_where:='where ' || condition_where; END IF; END IF; --order by 語句構造 IF "character_length"(condition_orderby)>0 THEN IF strpos(condition_orderby,'order ')!=1 THEN condition_orderby:='order by '||condition_orderby; END IF; END IF; --判斷pageindex是否合法及pagesize是否合法 IF pageindex<1 THEN pageindex:=1; END IF; IF pagesize<1 THEN pagesize:=20; END IF; _dynamic_getCount:='select count(*) from test3 '||condition_where|| ' ' ; EXECUTE _dynamic_getCount INTO _totalCount; IF _totalCount<1 THEN pageindex:=1; RETURN; END IF; --計算總共頁數 _tmpInt1:=_totalCount%pagesize; IF _tmpInt1=0 THEN _totalPages:=_totalCount / pagesize; ELSE _totalPages:=(_totalCount-_tmpInt1)/pagesize+1; END IF; IF _totalPages < pageindex then pageindex:=_totalPages; END IF; _theOffset:=(pageindex-1) * pagesize+1; _dymatic_sql:='select '||condition_columns||' from test3 '||condition_where||' '||condition_orderby||' limit '||pagesize||' '|| ' offset '||_theOffset||' '; --raise info '動態構造語句為:%',_dymatic_sql; return query EXECUTE _dymatic_sql; END; $$ language plpgsql VOLATILE; ------------------------------------ --用途:複雜形式的查詢語句,用於查詢多條記錄資料。 --這個是泛用型的,假如你要根據使用者輸入去查詢,那麼最好不要用這個了, --以免出現sql注入。 --引數說明: ---_offset int 需要取的記錄的開始位置 ---_limit int 需要獲取記錄的總條數,針對分頁而言,就是分頁的pagesize。 ---_columns varchar(800) 需要獲取的欄位 ---_where varchar(800) 需要過濾的條件譬如: where id<10 可以帶where,不過建議不要帶。 ---_orderby varchar(800) 需要進行排序的提交,譬如:order by id ---_totalCount int 返回總共記錄條數。 ------------------------------------ create or replace function test3_getPageByCondition( INOUT pageindex INT,out _totalPages INT,out _refcursor refcursor ) returns SETOF record AS $$ DECLARE condition_columns VARCHAR(800); DECLARE condition_where varchar(800); DECLARE condition_orderby VARCHAR(800); DECLARE _dymatic_sql VARCHAR(1600); DECLARE _beginNO INT; DECLARE _dynamic_getCount varchar(1600); DECLARE _theOffset INT; DECLARE _tmpInt1 INT; BEGIN condition_where:=ltrim(rtrim(COALESCE(_where,'order ')!=1 THEN condition_orderby:='order by '||condition_orderby; END IF; END IF; --判斷pageindex是否合法及pagesize是否合法 IF pageindex<1 THEN pageindex:=1; END IF; IF pagesize<1 THEN pagesize:=20; END IF; _dynamic_getCount:='select count(*) from test3 '||condition_where|| ' ' ; EXECUTE _dynamic_getCount INTO _totalCount; IF _totalCount<1 THEN pageindex:=1; RETURN; END IF; --計算總共頁數 _tmpInt1:=_totalCount%pagesize; IF _tmpInt1=0 THEN _totalPages:=_totalCount / pagesize; ELSE _totalPages:=(_totalCount-_tmpInt1)/pagesize+1; END IF; IF _totalPages < pageindex then pageindex:=_totalPages; END IF; _theOffset:=(pageindex-1) * pagesize+1; _dymatic_sql:='select '||condition_columns||' from test3 '||condition_where||' '||condition_orderby||' limit '||pagesize||' '|| ' offset '||_theOffset||' '; --raise info '動態構造語句為:%',_dymatic_sql; open _refcursor for EXECUTE _dymatic_sql; RETURN NEXT; END; $$ language plpgsql VOLATILE; ------------------------------------ --用途:獲取其中一條記錄 ------------------------------------ create or replace function test3_getRecord(in _id integer) returns SETOF test3 AS $$ BEGIN return query select * from test3 where t3id=_id LIMIT 1 OFFSET 0; END; $$ LANGUAGE plpgsql VOLATILE; ------------------------------------ --用途:複雜形式的查詢語句,用於查詢前面第幾條記錄,這個就相當好了 --這個是泛用型的,假如你要根據使用者輸入去查詢,那麼最好不要用這個了, --以免出現sql注入。 --引數說明: ---_topN int 需要取的topN條記錄。 ---_columns varchar(800) 需要獲取的欄位 ---_where varchar(800) 需要過濾的條件譬如: where id<10 可以帶where,不過建議不要帶。 ---_orderby varchar(800) 需要進行排序的提交,譬如:order by id ------------------------------------ create or replace function test3_getTopNbyCondition(IN _topN int,IN _orderby VARCHAR(800)) returns SETOF test3 AS $$ DECLARE condition_columns VARCHAR(800); DECLARE condition_where varchar(800); DECLARE condition_orderby VARCHAR(800); DECLARE _dymatic_sql VARCHAR(1600); BEGIN condition_where:=ltrim(rtrim(COALESCE(_where,'order ')!=1 THEN condition_orderby:='order by '||condition_orderby; END IF; END IF; _dymatic_sql:='select '||condition_columns||' from test2 '||condition_where||' '||condition_orderby||' limit '||CAST(_topN as VARCHAR)|| ' offset 0 '; --raise info '動態構造語句為:%',_dymatic_sql; return query EXECUTE _dymatic_sql; END; $$ language plpgsql VOLATILE; /****************************************************************** *****************************記錄刪除****************************** ******************************************************************/ ------------------------------------ --用途:刪除多條記錄 ------------------------------------ create or replace function test3_DeleteList(in ids VARCHAR(800),out status boolean,out msg VARCHAR(200)) returns record AS $$ DECLARE _arr_ids int[]; DECLARE _str_ids "text"; DECLARE _str_sql VARCHAR(1600); DECLARE _effects int; BEGIN IF "character_length"(ids)<1 THEN status:=false; msg:='沒有指定需要刪除的資料!'; return; end if; _arr_ids:=tools_str2intarray(ids,','); _str_ids:=tools_stringify(_arr_ids,'); --pkey為主鍵,自增的整數, <@ 表示判斷pkey是不是在數組裡面。是不是很方便? /*動態構造執行*/ --_str_sql:='DELETE FROM test3 where t3id in ('||_str_ids||') ;'; --EXECUTE _str_sql; /*直接執行*/ delete from test3 where t3id =ANY( _arr_ids); GET DIAGNOSTICS _effects = ROW_COUNT; IF _effects>0 THEN status:=true; msg:='成功刪除'||_effects||'條記錄!'; ELSE status:=false; msg:='沒有刪除任何記錄!'; end if; END $$ LANGUAGE plpgsql VOLATILE; /****************************************************************** ****************************新增及編輯***************************** ******************************************************************/ ------------------------------------ --用途:增加一條記錄 ------------------------------------ create or replace function test3_Insert( in __t3name varchar(400),in __t_birthday date,in __myage smallint,in __isadmin boolean,in __myintro text,in __price float,out __t3id integer,out _status boolean,out _msg varchar(200)) returns record AS $$ BEGIN Insert into test3 ( "t3name","t_birthday","myage","isadmin","myintro","price" ) values( __t3name,__t_birthday,__myage,__isadmin,__myintro,__price ); /*判斷新增記錄是否成功。*/ if FOUND then _status:=true; _msg:='成功新增記錄.'; __t3id:=currval(pg_get_serial_sequence('test3','t3id')); else _status:=false; _msg:='無法新增記錄!'; end if; end; $$ LANGUAGE plpgsql VOLATILE; ------------------------------------ --用途:修改一條記錄 ------------------------------------ create or replace function test3_Update( in __t3name varchar(400),in __t3id integer,out _msg varchar(200)) returns record AS $$ BEGIN update test3 set "t3name"=__t3name,"t_birthday"=__t_birthday,"myage"=__myage,"isadmin"=__isadmin,"myintro"=__myintro,"price"=__price where t3id=__t3id; /*判斷儲存記錄是否成功。*/ if FOUND then _status:=true; _msg:='成功儲存記錄.'; else _status:=false; _msg:='無法儲存記錄!'; end if; end; $$ LANGUAGE plpgsql VOLATILE;
對應dal呼叫檔案:
package EasisWeb.DAL; import EasisWeb.config.DBPool; import Easis.Common.StringUtil; import Easis.util.DataRow; import Easis.util.DataTable; import Easis.util.DataTableHelper; import java.util.Date; import Easis.DBUtility.PooledConnection; import java.sql.*; import java.util.List; import java.util.ArrayList; import Easis.util.OperationResult; import Easis.util.PagerResult; import EasisWeb.Model.test3Model; /** * 這是利用CodeGen工具生成的自動訪問資料庫的一個模板,作者為“碼農下的天橋” *生成的類名稱: * @author 碼農下的天橋 * @version 1.00 */ public class test3DAL { /*表格各種column*/ public static final String col_t3id="test3"; public static final String col_t3name="test3"; public static final String col_t_birthday="test3"; public static final String col_myage="test3"; public static final String col_isadmin="test3"; public static final String col_myintro="test3"; public static final String col_price="test3"; public static final String PKColumn="t3id"; /** *儲存過程名稱:test3_ListByCondition *儲存過程引數: *@param pageindex *@param pagesize *@param columns 需要獲取的欄位 *@param condition where條件語句 *@param orderColumn order by排序語句 * *@return 分頁物件 */ public PagerResult getPageListByCondition(int pageindex,int pagesize,String columns,String condition,String orderColumn){ PagerResult pres=new PagerResult(); //output引數定義 int _total = 0 ; int _pagesize = 0 ; int _pageindex = 0 ; int _totalpages = 0 ; //output引數定義結束 //呼叫儲存過程 DataTable res__datatable=new DataTable(); try{ PooledConnection __myconn=DBPool.getConnection(); __myconn.setAutoCommit(false); // return refcursor must within a transaction CallableStatement _stmt=__myconn.prepareCall("{ call test3_getPageByCondition( ?,?,?)}"); _stmt.setInt(1,pageindex); _stmt.setInt(2,pagesize); _stmt.registerOutParameter(1,Types.INTEGER); _stmt.registerOutParameter(2,Types.INTEGER); _stmt.setString(3,columns); _stmt.setString(4,condition); _stmt.setString(5,orderColumn); _stmt.registerOutParameter(6,Types.INTEGER); _stmt.registerOutParameter(7,Types.INTEGER); _stmt.registerOutParameter(8,Types.OTHER); _stmt.execute(); ResultSet __rslist=(ResultSet)_stmt.getObject(8); res__datatable=DataTableHelper.rs2datatable(__rslist); //取回引數 _total=_stmt.getInt(6); pres.totalrecords=_total; _pageindex=_stmt.getInt(1); pres.totalrecords=_total; _pagesize=_stmt.getInt(2); pres.pageindex=_pageindex; pres.pagesize=_pagesize; _totalpages=_stmt.getInt(7); pres.totalpages=_totalpages; pres.datasource=res__datatable; //--提交併還原 __myconn.commit(); __myconn.setAutoCommit(true); //返回遊標必須在一個事務中,提交完以後將autocommit還原。 //釋放資源 __rslist.close(); _stmt.close(); __myconn.close();} catch (Exception __e){ System.out.println("在執行[test3DAL]的List_Condition時候出現錯誤。"); __e.printStackTrace(); } return pres; } /** *儲存過程名稱:test3_Insert *儲存過程引數: *param t3id 【主鍵】 t3name t_birthday myage isadmin myintro price * *@return */ public OperationResult Insert(test3Model model){ OperationResult __ores=new OperationResult(); /*output引數定義*/ int t3id = 0 ; DataRow returnInfo=new DataRow(); boolean status = false ; String message = "" ; /*output引數定義結束*/ /*呼叫儲存過程*/ try{ PooledConnection __myconn=DBPool.getConnection(); CallableStatement _stmt=__myconn.prepareCall("{call test3_Insert(?,?)}"); _stmt.setObject(1,model.t3name,Types.VARCHAR); _stmt.setObject(2,new Timestamp(model.t_birthday.getTime()),Types.DATE); _stmt.setObject(3,model.myage,Types.SMALLINT); _stmt.setObject(4,model.isadmin,Types.BOOLEAN); _stmt.setObject(5,model.myintro,Types.VARCHAR); _stmt.setObject(6,model.price,Types.FLOAT); _stmt.registerOutParameter(7,Types.INTEGER,-1); _stmt.registerOutParameter(8,Types.BOOLEAN,1); _stmt.registerOutParameter(9,Types.VARCHAR,200); _stmt.execute(); /*取回引數*/ t3id=_stmt.getInt(7); status=_stmt.getBoolean(8); message=_stmt.getString(9); __ores.id= t3id; __ores.status=status; __ores.message=message; /*釋放資源*/ _stmt.close(); __myconn.close();} catch (Exception __e){ __e.printStackTrace(); __ores.message=__e.toString(); } return __ores; } /** *儲存過程名稱:test3_Update *儲存過程引數: * t3id【主鍵】 t3name t_birthday myage isadmin myintro price * *@return */ public OperationResult Update(test3Model model){ OperationResult __ores=new OperationResult(); /*output引數定義*/ boolean status = false ; String message = "" ; /*output引數定義結束*/ /*呼叫儲存過程*/ DataTable res__datatable=new DataTable(); try{ PooledConnection __myconn=DBPool.getConnection(); CallableStatement _stmt=__myconn.prepareCall("{ call test3_Update( ?,?)}"); _stmt.setObject(1,Types.FLOAT); _stmt.setInt(7,model.t3id); _stmt.registerOutParameter(8,400); _stmt.execute(); /*取回引數*/ status=_stmt.getBoolean(8); message=_stmt.getString(9); __ores.status=status; __ores.message=message; /*釋放資源*/ _stmt.close(); __myconn.close();} catch (Exception __e){ __e.printStackTrace(); } return __ores; } /** *儲存過程名稱:test3_DeleteList *儲存過程引數: *@param ids 【引數名稱:ids 引數型別:nvarchar 對應java型別:String 長度:400 】 * *@return */ public OperationResult DeleteList( String ids){ /*output引數定義*/ OperationResult __ores=new OperationResult(); boolean status = false ; String message = "" ; /*output引數定義結束*/ /*呼叫儲存過程*/ DataTable res__datatable=new DataTable(); try{ PooledConnection __myconn=DBPool.getConnection(); CallableStatement _stmt=__myconn.prepareCall("{ call test3_DeleteList( ?,?)}"); _stmt.setString(1,ids); _stmt.registerOutParameter(2,1); _stmt.registerOutParameter(3,400); _stmt.execute(); /*取回引數*/ status=_stmt.getBoolean(2); message=_stmt.getString(3); __ores.status=status; __ores.message=message; /*釋放資源*/ _stmt.close(); __myconn.close();} catch (Exception __e){ __e.printStackTrace(); } return __ores; } /** *儲存過程名稱:test3_GetRecord *儲存過程引數: *@param t3id 【引數名稱:id 引數型別:int 對應java型別:int 長度:非字元型別 】 * *@return DataTable物件。 */ public test3Model GetRecord( int t3id ){ /*呼叫儲存過程*/ DataTable res__datatable=new DataTable(); test3Model model=new test3Model(); try{ PooledConnection __myconn=DBPool.getConnection(); CallableStatement _stmt=__myconn.prepareCall("{ call test3_GetRecord( ?)}"); _stmt.setInt(1,t3id); ResultSet __rslist =_stmt.executeQuery(); res__datatable=DataTableHelper.rs2datatable(__rslist); model=tryParseModel(res__datatable.get(0)); /*釋放資源*/ __rslist.close(); _stmt.close(); __myconn.close();} catch (Exception __e){ __e.printStackTrace(); } return model; } /** *儲存過程名稱:test3_Top_Condition *儲存過程引數: *@param topN 【引數名稱:topN 引數型別:int 對應java型別:int 長度:非字元型別 】 *@param columns 【引數名稱:columns 引數型別:nvarchar 對應java型別:String 長度:800 】 *@param condition 【引數名稱:condition 引數型別:nvarchar 對應java型別:String 長度:800 】 *@param orderColumn 【引數名稱:orderColumn 引數型別:nvarchar 對應java型別:String 長度:800 】 * *@return DataTable物件。 */ public DataTable Top_Condition( int topN,String orderColumn ){ /*呼叫儲存過程*/ DataTable res__datatable=new DataTable(); try{ PooledConnection __myconn=DBPool.getConnection(); CallableStatement _stmt=__myconn.prepareCall("{ call test3_Top_Condition( ?,?)}"); _stmt.setInt(1,topN); _stmt.setString(2,columns); _stmt.setString(3,condition); _stmt.setString(4,orderColumn); ResultSet __rslist =_stmt.executeQuery(); res__datatable=DataTableHelper.rs2datatable(__rslist); /*釋放資源*/ __rslist.close(); _stmt.close(); __myconn.close();} catch (Exception __e){ __e.printStackTrace(); } return res__datatable; } public test3Model tryParseModel(DataRow drow){ test3Model model=new test3Model(); if(drow==null){ return model; } /* return "boolean"; return "Date"; return "double"; return "float"; return "int"; return "long"; return "String"; return "Object"; */ /*嘗試賦值*/ model.t3id = drow.get("t3id").toInt(); model.t3name = drow.get("t3name").toString(); model.t_birthday = drow.get("t_birthday").toDate(); model.myage = drow.get("myage").toInt(); model.isadmin = drow.get("isadmin").toBoolean(); model.myintro = drow.get("myintro").toString(); model.price = drow.get("price").toFloat(); return model; } public List<test3Model> tryParseList(List<DataRow> dataList){ List<test3Model> modellist=new ArrayList<test3Model>(); if(dataList==null){ return modellist; } for(DataRow drow :dataList){ modellist.add(tryParseModel(drow)); } return modellist; } }
這只是一份模板而已。
以上為個人經驗,希望能給大家一個參考,也希望大家多多支援我們。如有錯誤或未考慮完全的地方,望不吝賜教。