Spring Batch 3 - 讀數(shù)據(jù)庫寫文件

目的:通過jdbc連接讀取數(shù)據(jù)庫的記錄晴弃,寫入到單個文件中

源數(shù)據(jù)表

  • 我們還以上篇文章解析后的結(jié)果作為源數(shù)據(jù)表。
源數(shù)據(jù)源表

寫入的文本格式

  • 按照dateStr,userCode,time,path,userAgent 用逗號分隔作為一行

Spring Batch 代碼實現(xiàn)

依舊三部分:ItemReader焰络、ItemProcessor胧后、ItemWriter

  • ItemReader實現(xiàn):通過JDBC連接數(shù)據(jù)庫尊沸,執(zhí)行sql語句俊犯,把查詢出的結(jié)果集映射到實體類AccessBean中妇多。Spring Batch3提供了這種場景下的ItemReader實現(xiàn):org.springframework.batch.item.database.JdbcCursorItemReader
  • ItemProcessor實現(xiàn):這里不對數(shù)據(jù)處理燕侠,直接寫入文件中
  • ItemWriter實現(xiàn):把查詢到的數(shù)據(jù)按行組織數(shù)據(jù)者祖,逗號分隔,寫入到輸出文件中绢彤。Spring Batch3本身實現(xiàn)了寫文本的ItemWriter:org.springframework.batch.item.file.FlatFileItemWriter七问,可以自定義數(shù)據(jù)組織和分隔符等。

我們可以看到杖虾,幾乎沒有任何實現(xiàn)代碼烂瘫,很多事情Spring Batch都提供了默認(rèn)的實現(xiàn)媒熊。

Spring Batch Job配置

  • Job
 <batch:job id="readDB2FileJob">
        <batch:step id="readDB2FileStep">
            <batch:tasklet>
               <batch:chunk reader="jdbcItemReader" writer="fileWriter" commit-interval="5000" ></batch:chunk>
            </batch:tasklet>
        </batch:step>
    </batch:job>
  • logReader
  <!-- jdbc Reader -->
    <bean id="jdbcItemReader" class="org.springframework.batch.item.database.JdbcCursorItemReader">
       <!-- 數(shù)據(jù)源 -->
       <property name="dataSource" ref="dataSource"></property>
       <!-- 游標(biāo)一次讀多少行 -->
       <property name="fetchSize" value="5000"></property>
       <!-- 查詢sql -->
       <property name="sql">
           <value>
                <![CDATA[
                SELECT date_str, `path`, userCode, `time`, userAgent FROM access 
                ]]>
           </value>
       </property>
       <!-- 行映射對象 -->
       <property name="rowMapper">
           <bean class="org.springframework.jdbc.core.BeanPropertyRowMapper">
               <property name="mappedClass" value="com.me.springbatch.support.AccessBean"></property>
           </bean>
       </property>
    </bean>
  • fileWriter
   <!-- write to file Writer -->
    <bean id="fileWriter" class="org.springframework.batch.item.file.FlatFileItemWriter">
       <!-- 輸出文件 -->
       <property name="resource" value="file:/my/out.log"></property>
       <!-- 如果目標(biāo)文件已存在奇适,是否刪除 -->
       <property name="shouldDeleteIfExists" value="true"></property>
       <!-- 行策略 -->
       <property name="lineAggregator">
           <bean class="org.springframework.batch.item.file.transform.DelimitedLineAggregator">
               <!--  逗號分隔 -->
               <property name="delimiter" value=","></property>
               <property name="fieldExtractor">
                   <bean class="org.springframework.batch.item.file.transform.BeanWrapperFieldExtractor">
                       <!-- 行數(shù)據(jù)(字段、順序) -->
                       <property name="names" value="dateStr,userCode,time,path,userAgent"></property>
                   </bean>
               </property>
           </bean>
       </property>
    </bean>

FlatFileItemWriter 類有一個重要的屬性就是lineAggregator,用來描述如何組織行數(shù)據(jù)的芦鳍。Spring Batch提供了一個實現(xiàn)DelimitedLineAggregator 嚷往,在多數(shù)情況下都可以通過此類處理。

  • 運行Job
App.run("readDB2FileJob");

附完整代碼

https://git.oschina.net/heichong/spring-batch-demo

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末柠衅,一起剝皮案震驚了整個濱河市皮仁,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌菲宴,老刑警劉巖贷祈,帶你破解...
    沈念sama閱讀 223,002評論 6 519
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異喝峦,居然都是意外死亡势誊,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,357評論 3 400
  • 文/潘曉璐 我一進店門谣蠢,熙熙樓的掌柜王于貴愁眉苦臉地迎上來粟耻,“玉大人查近,你說我怎么就攤上這事〖访Γ” “怎么了霜威?”我有些...
    開封第一講書人閱讀 169,787評論 0 365
  • 文/不壞的土叔 我叫張陵,是天一觀的道長册烈。 經(jīng)常有香客問我戈泼,道長,這世上最難降的妖魔是什么赏僧? 我笑而不...
    開封第一講書人閱讀 60,237評論 1 300
  • 正文 為了忘掉前任矮冬,我火速辦了婚禮,結(jié)果婚禮上次哈,老公的妹妹穿的比我還像新娘胎署。我一直安慰自己,他們只是感情好窑滞,可當(dāng)我...
    茶點故事閱讀 69,237評論 6 398
  • 文/花漫 我一把揭開白布琼牧。 她就那樣靜靜地躺著,像睡著了一般哀卫。 火紅的嫁衣襯著肌膚如雪巨坊。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,821評論 1 314
  • 那天此改,我揣著相機與錄音趾撵,去河邊找鬼。 笑死共啃,一個胖子當(dāng)著我的面吹牛占调,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播移剪,決...
    沈念sama閱讀 41,236評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼究珊,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了纵苛?” 一聲冷哼從身側(cè)響起剿涮,我...
    開封第一講書人閱讀 40,196評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎攻人,沒想到半個月后取试,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,716評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡怀吻,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,794評論 3 343
  • 正文 我和宋清朗相戀三年瞬浓,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片烙博。...
    茶點故事閱讀 40,928評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡瑟蜈,死狀恐怖烟逊,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情铺根,我是刑警寧澤宪躯,帶...
    沈念sama閱讀 36,583評論 5 351
  • 正文 年R本政府宣布,位于F島的核電站位迂,受9級特大地震影響访雪,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜掂林,卻給世界環(huán)境...
    茶點故事閱讀 42,264評論 3 336
  • 文/蒙蒙 一臣缀、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧泻帮,春花似錦精置、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,755評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至元莫,卻和暖如春赖阻,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背踱蠢。 一陣腳步聲響...
    開封第一講書人閱讀 33,869評論 1 274
  • 我被黑心中介騙來泰國打工火欧, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人茎截。 一個月前我還...
    沈念sama閱讀 49,378評論 3 379
  • 正文 我出身青樓苇侵,卻偏偏與公主長得像,于是被迫代替她去往敵國和親稼虎。 傳聞我的和親對象是個殘疾皇子衅檀,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 45,937評論 2 361

推薦閱讀更多精彩內(nèi)容