大數據分析解決方案-資料下載頁
2025-04-28 03:50本頁面
【正文】 jdbc:mysql://+databaseIP+:+databasePort+/+databaseName,userName,pwd)。 17. (DROPTABLEIFEXISTS+tableName).execute()。 18. 19. StringBuildercreateQuery=newStringBuilder( 20. CREATETABLEIFNOTEXISTS+tableName+()。 21. for(Fieldfields:()) 22. { 23. if(().equalsIgnoreCase(String)) 24. (()+VARCHAR(500),)。 25. else26. (()++()+,)。 27. } 28. (thresholdTimeStamptimestamp))。 29. (()).execute()。 30. 31. //InsertQuery 32. StringBuilderinsertQuery=newStringBuilder(INSERTINTO+tableName+()。 33. StringtempCreateQuery=newString()。 34. for(Fieldfields:()) 35. { 36. (()+,)。 37. } 38. (thresholdTimeStamp).append()values()。 39. for(Fieldfields:()) 40. { 41. (?,)。 42. } 43. 44. (?))。 45. prepStatement=(())。 46. } 47. catch(SQLExceptione) 48. { 49. ()。 50. } 51. } 數據分批次的插入數據庫。插入的邏輯由Listting Seven中的execute（）方法提供。大部分的編碼都是用來實現可能存在不同類型輸入的解析。Listing Seven：數據插入的代碼部分。1. publicvoidexecute(Tupletuple,BasicOutputCollectorcollector) 2. { 3. batchExecuted=false。 4. if(tuple!=null) 5. { 6. Listamp。60。Objectamp。62。inputTupleList=(Listamp。60。Objectamp。62。)()。 7. intdbIndex=0。 8. for(inti=0。iamp。60。().size()。i++) 9. { 10. Fieldfield=().get(i)。 11. try{ 12. dbIndex=i+1。 13. if(().equalsIgnoreCase(String)) 14. (dbIndex,(i).toString())。 15. elseif(().equalsIgnoreCase(int)) 16. (dbIndex, 17. ((i).toString()))。 18. elseif(().equalsIgnoreCase(long)) 19. (dbIndex, 20. ((i).toString()))。 21. elseif(().equalsIgnoreCase(float)) 22. (dbIndex, 23. ((i).toString()))。 24. elseif(().equalsIgnoreCase(double)) 25. (dbIndex, 26. ((i).toString()))。 27. elseif(().equalsIgnoreCase(short)) 28. (dbIndex, 29. ((i).toString()))。 30. elseif(().equalsIgnoreCase(boolean)) 31. (dbIndex, 32. ((i).toString()))。 33. elseif(().equalsIgnoreCase(byte)) 34. (dbIndex, 35. ((i).toString()))。 36. elseif(().equalsIgnoreCase(Date)) 37. { 38. DatedateToAdd=null。 39. if(!((i)instanceofDate)) 40. { 41. DateFormatdf=newSimpleDateFormat(yyyyMMddhh:mm:ss)。 42. try 43. { 44. dateToAdd=((i).toString())。 45. } 46. catch(ParseExceptione) 47. { 48. (Datatypenotvalid)。 49. } 50. } 51. else52. { 53. dateToAdd=(Date)(i)。 54. sqlDate=new(())。 55. (dbIndex,sqlDate)。 56. } 57. } 58. catch(SQLExceptione) 59. { 60. ()。 61. } 62. } 63. Datenow=newDate()。 64. try65. { 66. (dbIndex+1,new(()))。 67. ()。 68. ()。 69. if(()==batchSize) 70. executeBatch()。 71. } 72. catch(SQLExceptione1) 73. { 74. ()。 75. } 76. } 77. else78. { 79. longcurTime=()。 80. longdiffInSeconds=(curTimest
公司管理相關推薦
鄂ICP備17016276號-1