• Java项目:家政服务系统(java+JSP+jquery+Servlet+Mysql)

    源码获取：俺的博客首页 "资源" 里下载！

    项目介绍


    本项目分为前后台，有普通用户与管理员两种角色，普通用户登录前台，管理员登录后台；

    用户角色包含以下功能：
    查看首页,客户注册,查看服务项目,查看服务项目详情,查看服务人员,查看家政新闻,在线留言等功能。

    管理员角色包含以下功能：
    管理员登录,管理员管理,客户信息管理,修改密码,员工信息管理,服务类别管理,服务项目管理,预约信息查询,留言管理,家政新闻管理,系统管理,友情链接添加,友情链接查询,系统公告设置等功能。

    环境需要

    1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。
    2.IDE环境：IDEA，Eclipse,Myeclipse都可以。推荐IDEA;
    3.tomcat环境：Tomcat 7.x,8.x,9.x版本均可
    4.硬件环境：windows 7/8/10 1G内存以上；或者 Mac OS； 
    5.数据库：MySql 5.7版本；
    6.是否Maven项目：否；

    技术栈

    JSP+CSS+JavaScript+jquery+Servlet+mysql

    使用说明

    1. 使用Navicat或者其它工具，在mysql中创建对应名称的数据库，并导入项目的sql文件；
    2. 使用IDEA/Eclipse/MyEclipse导入项目，Eclipse/MyEclipse导入时，若为maven项目请选择maven;
    若为maven项目，导入成功后请执行maven clean;maven install命令，然后运行；
    3. 将项目中dao/CommDAO.java配置文件中的数据库配置改为自己的配置;
    4. 运行项目，输入localhost:8080/jsp_jzfw_site 登录

     

     

     

     

     

     

     

    登录管理注册管理控制层： 

    1. public class MainCtrl extends HttpServlet {
    2.  
    3. 	public MainCtrl() {
    4. 		super();
    5. 	}
    6.  
    7. 	public void destroy() {
    8. 		super.destroy(); // Just puts "destroy" string in log
    9. 		// Put your code here
    10. 	}
    11.  
    12. 	public void doGet(HttpServletRequest request, HttpServletResponse response)
    13. 			throws ServletException, IOException {
    14.  
    15. 		this.doPost(request, response);
    16. 	}
    17.  
    18. 	public void go(String url,HttpServletRequest request, HttpServletResponse response)
    19. 	{
    20. 		try {
    21. 			request.getRequestDispatcher(url).forward(request, response);
    22. 		} catch (ServletException e) {
    23. 			e.printStackTrace();
    24. 		} catch (IOException e) {
    25. 			e.printStackTrace();
    26. 		}
    27. 	}
    28.  
    29. 	public void gor(String url,HttpServletRequest request, HttpServletResponse response)
    30. 	{
    31. 		try {
    32. 			response.sendRedirect(url);
    33. 		} catch (IOException e) {
    34. 			// TODO Auto-generated catch block
    35. 			e.printStackTrace();
    36. 		}
    37.  
    38. 	}
    39.  
    40. 	public void doPost(HttpServletRequest request, HttpServletResponse response)
    41. 			throws ServletException, IOException {
    42. 		response.setContentType("text/html");
    43. 		PrintWriter out = response.getWriter();
    44. 		String ac = request.getParameter("ac");
    45. 		if(ac==null)ac="";
    46. 		CommDAO dao = new CommDAO();
    47. 		String date = Info.getDateStr();
    48. 		String today = date.substring(0,10);
    49. 		String tomonth = date.substring(0,7);
    50.  
    51.  
    52. 		if(ac.equals("login"))
    53. 		{
    54. 			String username = request.getParameter("username");
    55. 			String password = request.getParameter("pwd1");
    56. 			String utype = request.getParameter("cx");
    57. 			String pagerandom = request.getParameter("pagerandom")==null?"":request.getParameter("pagerandom");
    58. 			String random = (String)request.getSession().getAttribute("random");
    59. 			if(!pagerandom.equals(random)&&request.getParameter("a")!=null)
    60. 			{
    61. 				request.setAttribute("random", "");
    62. 				go("/index.jsp", request, response);
    63. 			}
    64. 			else{
    65. 				String sql1="";
    66. 				if (utype.equals("注册用户"))
    67. 				{
    68. 					sql1 = "select * from yonghuzhuce where yonghuming='"+username+"' and mima='"+password+"' and issh='是'";
    69.  
    70. 				}
    71. 				else
    72. 				{
    73. 					sql1 = "select * from yuangongxinxi where gonghao='"+username+"' and mima='"+password+"'";
    74. 				}
    75. 				List<HashMap> userlist1 = dao.select(sql1);
    76. 				if(userlist1.size()==1)
    77. 				{
    78. 					if (utype.equals("注册用户"))
    79. 					{
    80. 						request.getSession(). setAttribute("username", userlist1.get(0).get("yonghuming"));
    81. 					}
    82. 					else
    83. 					{
    84. 						request.getSession(). setAttribute("username", userlist1.get(0).get("gonghao"));
    85. 					}
    86. 					request.getSession(). setAttribute("cx", utype);
    87. 					gor("index.jsp", request, response);
    88. 				}else{
    89. 					request.setAttribute("error", "");
    90. 					go("/index.jsp", request, response);
    91. 				}
    92.  
    93.  
    94.  
    95. 			}
    96. 		}
    97.  
    98. 		if(ac.equals("adminlogin"))
    99. 		{
    100. 			String username = request.getParameter("username");
    101. 			String password = request.getParameter("pwd");
    102. 			String utype = request.getParameter("cx");
    103. 			String pagerandom = request.getParameter("pagerandom")==null?"":request.getParameter("pagerandom");
    104. 			String random = (String)request.getSession().getAttribute("random");
    105. 			if(!pagerandom.equals(random)&&request.getParameter("a")!=null)
    106. 			{
    107. 				request.setAttribute("random", "");
    108. 				go("/login.jsp", request, response);
    109. 			}
    110. 			else{
    111. 				String sql1 = "select * from allusers where username='"+username+"' and pwd='"+password+"'  ";
    112. 				List<HashMap> userlist1 = dao.select(sql1);
    113. 				if(userlist1.size()==1)
    114. 				{
    115. 					request.getSession(). setAttribute("username", userlist1.get(0).get("username"));
    116. 					request.getSession(). setAttribute("cx",  userlist1.get(0).get("cx"));
    117. 					gor("main.jsp", request, response);
    118. 				}else{
    119. 					request.setAttribute("error", "");
    120. 					go("/login.jsp", request, response);
    121. 				}
    122.  
    123.  
    124.  
    125. 			}
    126. 		}
    127.  
    128.  
    129. 		//修改密码
    130. 		if(ac.equals("uppass"))
    131. 		{
    132. 			String olduserpass = request.getParameter("ymm");
    133. 			String userpass = request.getParameter("xmm1");
    134. 			String copyuserpass = request.getParameter("xmm2");
    135. 			HashMap m = dao.getmaps("yonghuming",(String)request.getSession().getAttribute("username"), "yonghuzhuce");
    136. 			if(!(((String)m.get("mima")).equals(olduserpass)))
    137. 			{
    138. 				request.setAttribute("error", "");
    139. 				go("mod2.jsp", request, response);
    140. 			}else{
    141. 				//String id = (String)user.get("id");
    142. 				String sql = "update yonghuzhuce set mima='"+userpass+"' where yonghuming='"+(String)request.getSession().getAttribute("username")+"'";
    143. 				dao.commOper(sql);
    144. 				request.setAttribute("suc", "");
    145. 				go("mod2.jsp", request, response);
    146. 			}
    147. 		}
    148.  
    149. 		//修改密码
    150. 		if(ac.equals("adminuppass"))
    151. 		{
    152. 			String olduserpass = request.getParameter("ymm");
    153. 			String userpass = request.getParameter("xmm1");
    154. 			String copyuserpass = request.getParameter("xmm2");
    155. 			//println(Info.getUser(request).get("id").toString());
    156. 			HashMap m = dao.getmaps("username",(String)request.getSession().getAttribute("username"), "allusers");
    157.  
    158. 			if(!(((String)m.get("pwd")).equals(olduserpass)))
    159. 			{
    160. 				request.setAttribute("error", "");
    161. 				go("mod.jsp", request, response);
    162. 			}else{
    163. 				//String id = (String)user.get("id");
    164. 				String sql = "update allusers set pwd='"+userpass+"' where username='"+(String)request.getSession().getAttribute("username")+"'";
    165. 				dao.commOper(sql);
    166. 				request.setAttribute("suc", "");
    167. 				go("mod.jsp", request, response);
    168. 			}
    169. 		}
    170.  
    171.  
    172. 		if(ac.equals("uploaddoc"))
    173. 		{
    174. 			try {
    175. 				String filename="";
    176. 				request.setCharacterEncoding("UTF-8");
    177. 				RequestContext  requestContext = new ServletRequestContext(request);
    178. 				if(FileUpload.isMultipartContent(requestContext)){
    179.  
    180. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    181. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    182. 					ServletFileUpload upload = new ServletFileUpload(factory);
    183. 					upload.setSizeMax(100*1024*1024);
    184. 					List items = new ArrayList();
    185.  
    186. 					items = upload.parseRequest(request);
    187.  
    188. 					FileItem fileItem = (FileItem) items.get(0);
    189. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    190. 					{
    191. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    192. 							File fullFile = new File(fileItem.getName());
    193. 							filename = Info.generalFileName(fullFile.getName());
    194. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    195. 							try {
    196. 								fileItem.write(newFile);
    197. 							} catch (Exception e) {
    198. 								e.printStackTrace();
    199. 							}
    200. 						}else{
    201. 						}
    202. 					}
    203. 				}
    204.  
    205. 				go("/js/uploaddoc.jsp?docname="+filename, request, response);
    206. 			} catch (Exception e1) {
    207. 				e1.printStackTrace();
    208. 			}
    209. 		}
    210.  
    211. 		if(ac.equals("uploaddoc2"))
    212. 		{
    213. 			try {
    214. 				String filename="";
    215. 				request.setCharacterEncoding("UTF-8");
    216. 				RequestContext  requestContext = new ServletRequestContext(request);
    217. 				if(FileUpload.isMultipartContent(requestContext)){
    218.  
    219. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    220. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    221. 					ServletFileUpload upload = new ServletFileUpload(factory);
    222. 					upload.setSizeMax(100*1024*1024);
    223. 					List items = new ArrayList();
    224.  
    225. 					items = upload.parseRequest(request);
    226.  
    227. 					FileItem fileItem = (FileItem) items.get(0);
    228. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    229. 					{
    230. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    231. 							File fullFile = new File(fileItem.getName());
    232. 							filename = Info.generalFileName(fullFile.getName());
    233. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    234. 							try {
    235. 								fileItem.write(newFile);
    236. 							} catch (Exception e) {
    237. 								e.printStackTrace();
    238. 							}
    239. 						}else{
    240. 						}
    241. 					}
    242. 				}
    243.  
    244. 				go("/js/uploaddoc2.jsp?docname="+filename, request, response);
    245. 			} catch (Exception e1) {
    246. 				e1.printStackTrace();
    247. 			}
    248. 		}
    249.  
    250.  
    251. 		if(ac.equals("uploaddoc3"))
    252. 		{
    253. 			try {
    254. 				String filename="";
    255. 				request.setCharacterEncoding("UTF-8");
    256. 				RequestContext  requestContext = new ServletRequestContext(request);
    257. 				if(FileUpload.isMultipartContent(requestContext)){
    258.  
    259. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    260. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    261. 					ServletFileUpload upload = new ServletFileUpload(factory);
    262. 					upload.setSizeMax(100*1024*1024);
    263. 					List items = new ArrayList();
    264.  
    265. 					items = upload.parseRequest(request);
    266.  
    267. 					FileItem fileItem = (FileItem) items.get(0);
    268. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    269. 					{
    270. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    271. 							File fullFile = new File(fileItem.getName());
    272. 							filename = Info.generalFileName(fullFile.getName());
    273. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    274. 							try {
    275. 								fileItem.write(newFile);
    276. 							} catch (Exception e) {
    277. 								e.printStackTrace();
    278. 							}
    279. 						}else{
    280. 						}
    281. 					}
    282. 				}
    283.  
    284. 				go("/js/uploaddoc3.jsp?docname="+filename, request, response);
    285. 			} catch (Exception e1) {
    286. 				e1.printStackTrace();
    287. 			}
    288. 		}
    289.  
    290. 		//导excel
    291. 		if(ac.equals("importexcel"))
    292. 		{
    293. 			String page = request.getParameter("page");
    294. 			String whzdstr = request.getParameter("whzdstr");
    295. 			String tablename = request.getParameter("tablename");
    296. 			try {
    297. 				String filename="";
    298. 				request.setCharacterEncoding("UTF-8");
    299. 				RequestContext  requestContext = new ServletRequestContext(request);
    300. 				if(FileUpload.isMultipartContent(requestContext)){
    301.  
    302. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    303. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    304. 					ServletFileUpload upload = new ServletFileUpload(factory);
    305. 					upload.setSizeMax(100*1024*1024);
    306. 					List items = new ArrayList();
    307.  
    308. 					items = upload.parseRequest(request);
    309.  
    310. 					FileItem fileItem = (FileItem) items.get(0);
    311. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    312. 					{
    313. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    314. 							File fullFile = new File(fileItem.getName());
    315. 							filename = Info.generalFileName(fullFile.getName());
    316. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    317. 							try {
    318. 								fileItem.write(newFile);
    319. 							} catch (Exception e) {
    320. 								e.printStackTrace();
    321. 							}
    322. 						}else{
    323. 						}
    324. 					}
    325.  
    326. 					if(filename.indexOf(".xls")>-1)
    327. 					{
    328. 						Workbook workbook;
    329. 						try {
    330. 							workbook = Workbook.getWorkbook(new File(request.getRealPath("/upfile/")+"/"+filename));
    331. 							//通过Workbook的getSheet方法选择第一个工作簿（从0开始）
    332. 							Sheet sheet = workbook.getSheet(0);
    333. 							//通过Sheet方法的getCell方法选择位置为C2的单元格（两个参数都从0开始）
    334. 							//int empty = 0;
    335. 							for(int i=1;i<1000;i++)
    336. 							{
    337. 								Cell cell = null;
    338. 								try{
    339. 									String isql = "insert into "+tablename+"(";
    340.  
    341. 									for(String str:whzdstr.split("-"))
    342. 									{
    343. 										isql+=str+",";
    344. 									}
    345. 									isql = isql.substring(0,isql.length()-1);
    346. 									isql+=")values(";
    347.  
    348. 									int j=0;
    349. 									int empty = 1;
    350. 									for(String str:whzdstr.split("-"))
    351. 									{
    352. 										cell = sheet.getCell(j,i);
    353. 										isql+="'"+cell.getContents()+"',";
    354. 										String content = cell.getContents()==null?"":cell.getContents();
    355. 										if(!"".equals(content.trim()))
    356. 										{
    357. 											empty = 0;
    358. 										}
    359. 										j++;
    360. 									}
    361. 									if(empty==1)continue;
    362. 									isql = isql.substring(0,isql.length()-1);
    363. 									isql+=")";
    364. 									dao.commOper(isql);
    365. 								}catch (Exception e) {
    366. 									continue;
    367. 								}
    368.  
    369. 							}
    370. 							workbook.close();
    371. 						} catch (Exception e) {
    372. 							e.printStackTrace();
    373. 						}
    374. 					}
    375. 				}
    376. 				go("/admin/"+page+"?docname="+filename, request, response);
    377. 			} catch (Exception e1) {
    378. 				e1.printStackTrace();
    379. 			}
    380. 		}
    381.  
    382.  
    383. 		if(ac.equals("uploadimg"))
    384. 		{
    385. 			try {
    386. 				String filename="";
    387. 				request.setCharacterEncoding("UTF-8");
    388. 				RequestContext  requestContext = new ServletRequestContext(request);
    389. 				if(FileUpload.isMultipartContent(requestContext)){
    390.  
    391. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    392. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    393. 					ServletFileUpload upload = new ServletFileUpload(factory);
    394. 					upload.setSizeMax(100*1024*1024);
    395. 					List items = new ArrayList();
    396.  
    397. 					items = upload.parseRequest(request);
    398.  
    399. 					FileItem fileItem = (FileItem) items.get(0);
    400. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    401. 					{
    402. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    403. 							File fullFile = new File(fileItem.getName());
    404. 							filename = Info.generalFileName(fullFile.getName());
    405. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    406. 							try {
    407. 								fileItem.write(newFile);
    408. 							} catch (Exception e) {
    409. 								e.printStackTrace();
    410. 							}
    411. 						}else{
    412. 						}
    413. 					}
    414. 				}
    415.  
    416. 				go("/js/uploadimg.jsp?filename="+filename, request, response);
    417. 			} catch (Exception e1) {
    418. 				e1.printStackTrace();
    419. 			}
    420. 		}
    421.  
    422.  
    423. 		if(ac.equals("uploadimg2"))
    424. 		{
    425. 			try {
    426. 				String filename="";
    427. 				request.setCharacterEncoding("UTF-8");
    428. 				RequestContext  requestContext = new ServletRequestContext(request);
    429. 				if(FileUpload.isMultipartContent(requestContext)){
    430.  
    431. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    432. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    433. 					ServletFileUpload upload = new ServletFileUpload(factory);
    434. 					upload.setSizeMax(100*1024*1024);
    435. 					List items = new ArrayList();
    436.  
    437. 					items = upload.parseRequest(request);
    438.  
    439. 					FileItem fileItem = (FileItem) items.get(0);
    440. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    441. 					{
    442. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    443. 							File fullFile = new File(fileItem.getName());
    444. 							filename = Info.generalFileName(fullFile.getName());
    445. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    446. 							try {
    447. 								fileItem.write(newFile);
    448. 							} catch (Exception e) {
    449. 								e.printStackTrace();
    450. 							}
    451. 						}else{
    452. 						}
    453. 					}
    454. 				}
    455.  
    456. 				go("/js/uploadimg2.jsp?filename="+filename, request, response);
    457. 			} catch (Exception e1) {
    458. 				e1.printStackTrace();
    459. 			}
    460. 		}
    461.  
    462. 		if(ac.equals("uploadimg3"))
    463. 		{
    464. 			try {
    465. 				String filename="";
    466. 				request.setCharacterEncoding("UTF-8");
    467. 				RequestContext  requestContext = new ServletRequestContext(request);
    468. 				if(FileUpload.isMultipartContent(requestContext)){
    469.  
    470. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    471. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    472. 					ServletFileUpload upload = new ServletFileUpload(factory);
    473. 					upload.setSizeMax(100*1024*1024);
    474. 					List items = new ArrayList();
    475.  
    476. 					items = upload.parseRequest(request);
    477.  
    478. 					FileItem fileItem = (FileItem) items.get(0);
    479. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    480. 					{
    481. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    482. 							File fullFile = new File(fileItem.getName());
    483. 							filename = Info.generalFileName(fullFile.getName());
    484. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    485. 							try {
    486. 								fileItem.write(newFile);
    487. 							} catch (Exception e) {
    488. 								e.printStackTrace();
    489. 							}
    490. 						}else{
    491. 						}
    492. 					}
    493. 				}
    494.  
    495. 				go("/js/uploadimg3.jsp?filename="+filename, request, response);
    496. 			} catch (Exception e1) {
    497. 				e1.printStackTrace();
    498. 			}
    499. 		}
    500.  
    501. 		if(ac.equals("uploadimg4"))
    502. 		{
    503. 			try {
    504. 				String filename="";
    505. 				request.setCharacterEncoding("UTF-8");
    506. 				RequestContext  requestContext = new ServletRequestContext(request);
    507. 				if(FileUpload.isMultipartContent(requestContext)){
    508.  
    509. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    510. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    511. 					ServletFileUpload upload = new ServletFileUpload(factory);
    512. 					upload.setSizeMax(100*1024*1024);
    513. 					List items = new ArrayList();
    514.  
    515. 					items = upload.parseRequest(request);
    516.  
    517. 					FileItem fileItem = (FileItem) items.get(0);
    518. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    519. 					{
    520. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    521. 							File fullFile = new File(fileItem.getName());
    522. 							filename = Info.generalFileName(fullFile.getName());
    523. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    524. 							try {
    525. 								fileItem.write(newFile);
    526. 							} catch (Exception e) {
    527. 								e.printStackTrace();
    528. 							}
    529. 						}else{
    530. 						}
    531. 					}
    532. 				}
    533.  
    534. 				go("/js/uploadimg4.jsp?filename="+filename, request, response);
    535. 			} catch (Exception e1) {
    536. 				e1.printStackTrace();
    537. 			}
    538. 		}
    539.  
    540. 		if(ac.equals("uploadimg5"))
    541. 		{
    542. 			try {
    543. 				String filename="";
    544. 				request.setCharacterEncoding("UTF-8");
    545. 				RequestContext  requestContext = new ServletRequestContext(request);
    546. 				if(FileUpload.isMultipartContent(requestContext)){
    547.  
    548. 					DiskFileItemFactory factory = new DiskFileItemFactory();
    549. 					factory.setRepository(new File(request.getRealPath("/upfile/")+"/"));
    550. 					ServletFileUpload upload = new ServletFileUpload(factory);
    551. 					upload.setSizeMax(100*1024*1024);
    552. 					List items = new ArrayList();
    553.  
    554. 					items = upload.parseRequest(request);
    555.  
    556. 					FileItem fileItem = (FileItem) items.get(0);
    557. 					if(fileItem.getName()!=null && fileItem.getSize()!=0)
    558. 					{
    559. 						if(fileItem.getName()!=null && fileItem.getSize()!=0){
    560. 							File fullFile = new File(fileItem.getName());
    561. 							filename = Info.generalFileName(fullFile.getName());
    562. 							File newFile = new File(request.getRealPath("/upfile/")+"/" + filename);
    563. 							try {
    564. 								fileItem.write(newFile);
    565. 							} catch (Exception e) {
    566. 								e.printStackTrace();
    567. 							}
    568. 						}else{
    569. 						}
    570. 					}
    571. 				}
    572.  
    573. 				go("/js/uploadimg5.jsp?filename="+filename, request, response);
    574. 			} catch (Exception e1) {
    575. 				e1.printStackTrace();
    576. 			}
    577. 		}
    578.  
    579.  
    580. 		dao.close();
    581. 		out.flush();
    582. 		out.close();
    583. 	}
    584.  
    585.  
    586. 	public void init() throws ServletException {
    587. 		// Put your code here
    588. 	}
    589.  
    590.  
    591.  
    592. }

    上传管理控制层：

    1. public class Upload extends HttpServlet {
    2.  
    3. 	/**
    4. 	 * Constructor of the object.
    5. 	 */
    6. 	public Upload() {
    7. 		super();
    8. 	}
    9.  
    10. 	/**
    11. 	 * Destruction of the servlet. <br>
    12. 	 */
    13. 	public void destroy() {
    14. 		super.destroy(); // Just puts "destroy" string in log
    15. 		// Put your code here
    16. 	}
    17.  
    18. 	/**
    19. 	 * The doGet method of the servlet. <br>
    20. 	 *
    21. 	 * This method is called when a form has its tag value method equals to get.
    22. 	 * 
    23. 	 * @param request the request send by the client to the server
    24. 	 * @param response the response send by the server to the client
    25. 	 * @throws ServletException if an error occurred
    26. 	 * @throws IOException if an error occurred
    27. 	 */
    28. 	public void doGet(HttpServletRequest request, HttpServletResponse response)
    29. 			throws ServletException, IOException {
    30.  
    31. 		this.doPost(request, response);
    32. 	}
    33.  
    34. 	/**
    35. 	 * The doPost method of the servlet. <br>
    36. 	 *
    37. 	 * This method is called when a form has its tag value method equals to post.
    38. 	 * 
    39. 	 * @param request the request send by the client to the server
    40. 	 * @param response the response send by the server to the client
    41. 	 * @throws ServletException if an error occurred
    42. 	 * @throws IOException if an error occurred
    43. 	 */
    44. 	public void doPost(HttpServletRequest request, HttpServletResponse response)
    45. 			throws ServletException, IOException {
    46.  
    47. 		StringBuffer   sb   =   new   StringBuffer(50);   
    48. 		 response.setContentType("application/x-msdownload;charset=UTF-8");   
    49.         try {
    50. 			response.setHeader("Content-Disposition",   new   String(sb.toString()   
    51. 			         .getBytes(),   "ISO8859-1"));
    52. 		} catch (UnsupportedEncodingException e1) {
    53. 			// TODO Auto-generated catch block
    54. 			e1.printStackTrace();
    55. 		}
    56. 		 String filename = request.getParameter("filename");
    57. 		  if (request.getHeader("User-Agent").toLowerCase().indexOf("firefox") > 0){
    58. 		     try {
    59. 				filename = new String(filename.getBytes("UTF-8"), "ISO8859-1");
    60. 			} catch (UnsupportedEncodingException e) {
    61. 				// TODO Auto-generated catch block
    62. 				e.printStackTrace();
    63. 			}
    64. 		 }
    65. 		 else 
    66. 		      if (request.getHeader("User-Agent").toUpperCase().indexOf("MSIE") > 0){
    67. 		           try {
    68. 					filename = URLEncoder.encode(filename, "UTF-8");
    69. 				} catch (UnsupportedEncodingException e) {
    70. 					// TODO Auto-generated catch block
    71. 					 
    72. 				}
    73. 		      }
    74. 		 response.setContentType("text/plain");
    75. 		 response.setHeader("Location",filename);
    76. 		 response.reset();
    77. 		 response.setHeader("Cache-Control", "max-age=0" );
    78. 		 response.setHeader("Content-Disposition", "attachment; filename=" + filename);
    79. 		   
    80.  
    81. 		    try {
    82. 				       BufferedInputStream bis = null;
    83. 					   BufferedOutputStream bos = null;
    84. 					   OutputStream fos = null;
    85. 					  // File f = new File(request.getRealPath("/upfile/")+"/"+filename);
    86. 					   //System.out.println(f);
    87. 					   bis = new BufferedInputStream((InputStream)new FileInputStream(request.getRealPath("/upfile/")+"/"+filename));
    88. 					    fos = response.getOutputStream();
    89. 					    bos = new BufferedOutputStream(fos);
    90.  
    91. 					    int bytesRead = 0;
    92. 					    byte[] buffer = new byte[5 * 1024];
    93. 					    while ((bytesRead = bis.read(buffer)) != -1) {
    94. 					     bos.write(buffer, 0, bytesRead);
    95. 					    }
    96. 					    bos.close();
    97. 					    bis.close();
    98. 					    fos.close();
    99. 				
    100. 		               new Info().delPic(request.getRealPath("/upfile/")+"/", filename);
    101. 		     } catch (Exception e) {
    102. 				 
    103. 			}finally{
    104. 			}
    105. 	}
    106.  
    107. 	/**
    108. 	 * Initialization of the servlet. <br>
    109. 	 *
    110. 	 * @throws ServletException if an error occurs
    111. 	 */
    112. 	public void init() throws ServletException {
    113. 		// Put your code here
    114. 	}
    115.  
    116. }

    业务处理DAO层：

    1. public class CommDAO
    2. {
    3. 	public static String dbname = "";
    4. 	public static String dbtype = "";
    5.  
    6. 	public static Connection conn = null;
    7.  
    8. 	public CommDAO()
    9. 	{
    10. 		conn = this.getConn();
    11. 	}
    12.  
    13. 	//给字段做加减法
    14. 	public void jiajian(String tablename,String colname,String id,String num)
    15. 	{
    16. 		HashMap map = this.getmap(id, tablename);
    17. 		String value = map.get(colname).toString();
    18. 		if(value.equals(""))value="0";
    19. 		int i = Integer.parseInt(value);
    20. 		int j = Integer.parseInt(num);
    21. 		commOper("update "+tablename+" set "+colname+" = "+(i+j)+" where id="+id);
    22. 	}
    23.  
    24. 	//	该方法返回一个table 用于流动图片
    25. 	public String DynamicImage(String categoryid,int cut,int width,int height){
    26.  
    27. 		StringBuffer imgStr = new StringBuffer();
    28. 		StringBuffer thePics1 = new StringBuffer();
    29. 		StringBuffer theLinks1 = new StringBuffer();
    30. 		StringBuffer theTexts1 = new StringBuffer();
    31.  
    32. 		imgStr.append("<div id=picViwer1  style='background-color: #ffffff' align=center></div><SCRIPT src='js/dynamicImage.js' type=text/javascript></SCRIPT>\n<script language=JavaScript>\n");
    33. 		thePics1.append("var thePics1=\n'");
    34. 		theLinks1.append("var theLinks1='");
    35. 		theTexts1.append("var theTexts1='");
    36.  
    37. 		List<HashMap> co = this.select("select * from xinwentongzhi where shouyetupian<>'' and shouyetupian<>'null'  and shouyetupian  like '%.jpg' order by id desc",1,6);
    38. 		int i = co.size();
    39.  
    40. 		int j = 0;
    41. 		for(HashMap b:co)
    42. 		{
    43. 			j++;
    44. 			int id = Integer.parseInt(b.get("id").toString()) ;
    45. 			String title = Info.subStr(b.get("biaoti").toString(), 21) ;
    46.  
    47. 			String url = ""+b.get("shouyetupian");
    48.  
    49. 			String purl = "gg_detail.jsp?id="+b.get("id");
    50.  
    51. 			if(j!=i){
    52. 				thePics1.append(url.replaceAll("\n", "")+"|");
    53. 				theLinks1.append(purl+"|");
    54. 				theTexts1.append(title+"|");
    55. 			}
    56. 			if(j==i)
    57. 			{
    58. 				thePics1.append(url.replaceAll("\n", ""));
    59. 				theLinks1.append("gg_detail.jsp?id="+b.get("id"));
    60. 				theTexts1.append(title);
    61. 			}
    62.  
    63. 		}
    64. 		thePics1.append("';");
    65.  
    66. 		theLinks1.append("';");
    67. 		theTexts1.append("';");
    68. 		imgStr.append(thePics1+"\n");
    69. 		imgStr.append(theLinks1+"\n");
    70. 		imgStr.append(theTexts1+"\n");
    71. 		imgStr.append("\n setPic(thePics1,theLinks1,theTexts1,"+width+","+height+",'picViwer1');</script>");
    72. 		return imgStr.toString();
    73. 	}
    74.  
    75. 	public HashMap getmap(String id,String table)
    76. 	{
    77. 		List<HashMap> list = new ArrayList();
    78. 		try {
    79. 			Statement st = conn.createStatement();
    80. 			//System.out.println("select * from "+table+" where id="+id);
    81. 			ResultSet rs = st.executeQuery("select * from "+table+" where id="+id);
    82. 			ResultSetMetaData rsmd = rs.getMetaData();
    83. 			while(rs.next())
    84. 			{
    85. 				HashMap map = new HashMap();
    86. 				int i = rsmd.getColumnCount();
    87. 				for(int j=1;j<=i;j++)
    88. 				{
    89. 					if(!rsmd.getColumnName(j).equals("ID"))
    90. 					{
    91. 						String str = rs.getString(j)==null?"": rs.getString(j);
    92. 						if(str.equals("null"))str = "";
    93. 						map.put(rsmd.getColumnName(j), str);
    94. 					}
    95. 					else
    96. 						map.put("id", rs.getString(j));
    97. 				}
    98. 				list.add(map);
    99. 			}
    100. 			rs.close();
    101. 			st.close();
    102. 		} catch (SQLException e) {
    103. 			// TODO Auto-generated catch block
    104. 			e.printStackTrace();
    105. 		}
    106. 		return list.get(0);
    107. 	}
    108.  
    109. 	public HashMap getmaps(String nzd,String zdz,String table)
    110. 	{
    111. 		List<HashMap> list = new ArrayList();
    112. 		try {
    113. 			Statement st = conn.createStatement();
    114. 			//System.out.println("select * from "+table+" where "+nzd+"='"+zdz+"'");
    115. 			ResultSet rs = st.executeQuery("select * from "+table+" where "+nzd+"='"+zdz+"'");
    116. 			ResultSetMetaData rsmd = rs.getMetaData();
    117. 			while(rs.next())
    118. 			{
    119. 				HashMap map = new HashMap();
    120. 				int i = rsmd.getColumnCount();
    121. 				for(int j=1;j<=i;j++)
    122. 				{
    123. 					if(!rsmd.getColumnName(j).equals("ID"))
    124. 					{
    125. 						String str = rs.getString(j)==null?"": rs.getString(j);
    126. 						if(str.equals("null"))str = "";
    127. 						map.put(rsmd.getColumnName(j), str);
    128. 					}
    129. 					else
    130. 						map.put("id", rs.getString(j));
    131. 				}
    132. 				list.add(map);
    133. 			}
    134. 			rs.close();
    135. 			st.close();
    136. 		} catch (SQLException e) {
    137. 			// TODO Auto-generated catch block
    138. 			e.printStackTrace();
    139. 		}
    140. 		return list.get(0);
    141. 	}
    142.  
    143. 	public String insert(HttpServletRequest request,HttpServletResponse response, String tablename,HashMap extmap,boolean alert,boolean reflush,String tzurl)
    144. 	{
    145. 		extmap.put("addtime", Info.getDateStr());
    146. 		if(request.getParameter("f")!=null){
    147. 			HashMap typemap = new HashMap();
    148. 			ArrayList<String> collist = new ArrayList();
    149. 			String sql = "insert into "+tablename+"(";
    150.  
    151. 			Connection conn = this.getConn();
    152. 			try {
    153. 				Statement st = conn.createStatement();
    154. 				ResultSet rs = st.executeQuery("select * from "+tablename);
    155. 				ResultSetMetaData rsmd = rs.getMetaData();
    156. 				int i = rsmd.getColumnCount();
    157.  
    158. 				for(int j=1;j<=i;j++)
    159. 				{
    160. 					if(rsmd.getColumnName(j).equals("id"))continue;
    161. 					if(rsmd.getColumnName(j).equals("ID"))continue;
    162. 					if(rsmd.getColumnName(j).equals("iD"))continue;
    163. 					if(rsmd.getColumnName(j).equals("Id"))continue;
    164. 					typemap.put(rsmd.getColumnName(j)+"---", rsmd.getColumnTypeName(j));
    165. 					collist.add(rsmd.getColumnName(j));
    166. 					sql+=rsmd.getColumnName(j)+",";
    167. 				}
    168. 				sql = sql.substring(0,sql.length()-1);
    169.  
    170. 				sql+=") values(";
    171. 				rs.close();
    172. 				st.close();
    173. 			} catch (SQLException e) {
    174. 				e.printStackTrace();
    175. 			}
    176. 			Enumeration enumeration = request.getParameterNames();
    177. 			String names = ",";
    178. 			while(enumeration.hasMoreElements())
    179. 			{
    180. 				names += enumeration.nextElement().toString()+",";
    181. 			}
    182. 			try {
    183. 				Statement st = conn.createStatement();
    184. 				for(String str:collist)
    185. 				{
    186. 					if(names.indexOf(","+str+",")>-1)
    187. 					{
    188. 						String[] values = request.getParameterValues(str);
    189. 						String value="";
    190. 						for(String vstr:values)
    191. 						{
    192. 							if(vstr==null)vstr="";
    193. 							if(vstr.equals("null"))vstr="";
    194. 							if(vstr.trim().equals(""))continue;
    195.  
    196. 							if(request.getParameter(vstr)!=null&&!"".equals(request.getParameter(vstr))&&request.getParameter("dk-"+str+"-value")!=null)
    197. 							{
    198. 								String dkv = request.getParameter(vstr);
    199. 								String dknamevalue = request.getParameter("dk-"+str+"-value");
    200. 								vstr+=" - "+dknamevalue+":"+dkv;
    201. 							}
    202.  
    203. 							value+=vstr+" ~ ";
    204. 						}
    205. 						if(value==null)value="";
    206. 						if(value.equals("null"))value="";
    207. 						if(value.length()>0)value=value.substring(0,value.length()-3);
    208.  
    209. 						if(typemap.get(str+"---").equals("int"))
    210. 						{
    211. 							sql+=(value.equals("")?-10:value)+",";
    212. 						}else{
    213. 							sql+="'"+(value.equals("null")?"":value)+"',";
    214. 						}
    215. 					}else{
    216. 						if(typemap.get(str+"---").equals("int"))
    217. 						{
    218. 							sql+=(extmap.get(str)==null?"":extmap.get(str))+",";
    219. 						}else{
    220. 							sql+="'"+(extmap.get(str)==null?"":extmap.get(str))+"',";
    221. 						}
    222. 					}
    223. 				}
    224.  
    225. 				sql=sql.substring(0,sql.length()-1)+")";
    226. 				System.out.println(sql);
    227. 				this.commOper(sql);
    228.  
    229. 				st.close();
    230.  
    231. 			} catch (SQLException e) {
    232. 				e.printStackTrace();
    233. 			}
    234. 			String str = "";
    235. 			if(!reflush)
    236. 				str += "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd\"> \n";
    237. 			str +=	"<script language=javascript>\n";
    238. 			if(alert){
    239. 				str+="alert('操作成功');\n";
    240. 			}
    241. 			if(tzurl.equals(""))
    242. 			{
    243. 				if(reflush){
    244. 					str+="parent.location=parent.location;\n";
    245. 				}else{
    246. 					str+="window.location=String(window.location).replace(new RegExp('f=f', 'g'), '');";
    247. 				}
    248. 			}
    249. 			else
    250. 			{
    251. 				str+="location.href='"+tzurl+"';\n";
    252. 			}
    254. 			str+="</script>";
    256. 			PrintWriter wrt = null;
    257. 			try {
    258. 				wrt = response.getWriter();
    259. 			} catch (IOException e) {
    260. 				// TODO Auto-generated catch block
    261. 				e.printStackTrace();
    262. 			}
    263. 			wrt.write(str);
    264. 		}
    266. 		return "";
    267. 	}
    269. 	public void delete(HttpServletRequest request,String tablename)
    270. 	{
    272. 		int i = 0;
    273. 		try {
    274. 			String did = request.getParameter("did");
    275. 			if(did==null)did = request.getParameter("scid");
    276. 			if(did!=null){
    277. 				if(did.length()>0){
    278. 					Statement st = conn.createStatement();
    279. 					System.out.println("delete from "+tablename+" where id="+did);
    280. 					st.execute("delete from "+tablename+" where id="+did);
    281. 					st.close();
    282. 				}
    283. 			}
    284.  
    285. 		} catch (SQLException e) {
    286. 			// TODO Auto-generated catch block
    287. 			e.printStackTrace();
    288. 		}
    289. 	}
    290.  
    291. 	public String getCols(String table)
    292. 	{
    293. 		String str = "";
    294. 		Connection conn = this.getConn();
    295. 		try {
    296. 			Statement st = conn.createStatement();
    297. 			ResultSet rs = st.executeQuery("select * from "+table);
    298. 			ResultSetMetaData rsmd = rs.getMetaData();
    299.  
    300. 			int i = rsmd.getColumnCount();
    301. 			for(int j=2;j<=i;j++)
    302. 			{
    303. 				str+=rsmd.getColumnName(j)+",";
    304. 			}
    305.  
    306. 		}catch (Exception e) {
    307. 			e.printStackTrace();
    308. 		}
    309. 		str = str.substring(0,str.length()-1);
    310.  
    311. 		return str;
    312. 	}
    313.  
    314. 	public String update(HttpServletRequest request,HttpServletResponse response, String tablename,HashMap extmap,boolean alert,boolean reflush,String tzurl)
    315. 	{
    316. 		if(request.getParameter("f")!=null){
    317. 			Enumeration enumeration = request.getParameterNames();
    318. 			String names = ",";
    319. 			while(enumeration.hasMoreElements())
    320. 			{
    321. 				names += enumeration.nextElement().toString()+",";
    322. 			}
    323. 			HashMap typemap = new HashMap();
    324. 			ArrayList<String> collist = new ArrayList();
    325. 			String sql = "update "+tablename+" set ";
    326. 			Connection conn = this.getConn();
    327. 			try {
    328. 				Statement st = conn.createStatement();
    329. 				ResultSet rs = st.executeQuery("select * from "+tablename);
    330. 				ResultSetMetaData rsmd = rs.getMetaData();
    331. 				int i = rsmd.getColumnCount();
    332. 				System.out.println(i);
    333. 				for(int j=1;j<=i;j++)
    334. 				{
    335. 					if(rsmd.getColumnName(j).equals("id"))continue;
    336. 					if(rsmd.getColumnName(j).equals("ID"))continue;
    337. 					if(rsmd.getColumnName(j).equals("Id"))continue;
    338. 					if(rsmd.getColumnName(j).equals("iD"))continue;
    339. 					typemap.put(rsmd.getColumnName(j)+"---", rsmd.getColumnTypeName(j));
    340. 					collist.add(rsmd.getColumnName(j));
    341. 					if(names.indexOf(","+rsmd.getColumnName(j)+",")>-1)
    342. 					{
    343.  
    344. 						String[] values = request.getParameterValues(rsmd.getColumnName(j));
    345. 						String value="";
    346. 						for(String vstr:values)
    347. 						{
    348. 							if(vstr==null)vstr="";
    349. 							if(vstr.equals("null"))vstr="";
    350. 							if(vstr.trim().equals(""))continue;
    351.  
    352. 							if(request.getParameter(vstr)!=null&&!"".equals(request.getParameter(vstr))&&request.getParameter("dk-"+rsmd.getColumnName(j)+"-value")!=null)
    353. 							{
    354. 								String dkv = request.getParameter(vstr);
    355. 								String dknamevalue = request.getParameter("dk-"+rsmd.getColumnName(j)+"-value");
    356. 								vstr+=" - "+dknamevalue+":"+dkv;
    357. 								System.out.println(vstr);
    358. 							}
    359. 							//if(vstr.length()<)
    360. 							value+=vstr+" ~ ";
    361. 						}
    362. 						if(value==null)value="";
    363. 						if(value.equals("null"))value="";
    364. 						if(value.length()>0)value=value.substring(0,value.length()-3);
    365.  
    366. 						if(rsmd.getColumnTypeName(j).equals("int"))
    367. 						{
    368. 							sql+=rsmd.getColumnName(j)+"="+value+",";
    369. 						}else{
    370. 							sql+=rsmd.getColumnName(j)+"='"+value+"',";
    371. 						}
    372. 					}else{
    373. 						if(extmap.get(rsmd.getColumnName(j))!=null)
    374. 						{
    375. 							if(rsmd.getColumnTypeName(j).equals("int"))
    376. 							{
    377. 								sql+=rsmd.getColumnName(j)+"="+extmap.get(rsmd.getColumnName(j))+",";
    378. 							}else{
    379. 								sql+=rsmd.getColumnName(j)+"='"+extmap.get(rsmd.getColumnName(j))+"',";
    380. 							}
    381. 						}
    382. 					}
    383. 				}
    384. 				sql = sql.substring(0,sql.length()-1);
    385. 				sql+=" where id="+request.getParameter("id");
    386. 				System.out.println(sql);
    387. 				Statement st1 = conn.createStatement();
    388. 				st1.execute(sql);
    389. 				st1.close();
    390. 				rs.close();
    391. 				st.close();
    392.  
    393. 			} catch (SQLException e) {
    394. 				e.printStackTrace();
    395. 			}
    396. 			String str = "";
    397. 			if(!reflush)
    398. 				str += "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//EN\" \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd\">\n" ;
    399. 			str +=	"<script language=javascript>\n";
    400. 			if(alert){
    401. 				str+="alert('操作成功');\n";
    402. 			}
    403. 			if(tzurl.equals(""))
    404. 			{
    405. 				if(reflush){
    406. 					str+="parent.location=parent.location;\n";
    407. 				}else{
    408. 					str+="window.location=String(window.location).replace(new RegExp('f=f', 'g'), '');";
    409. 				}
    410. 			}
    411. 			else
    412. 			{
    413. 				str+="location.href='"+tzurl+"';\n";
    414. 			}
    416. 			str+="</script>\n";
    418. 			PrintWriter wrt = null;
    419. 			try {
    420. 				//request.get
    421. 				wrt = response.getWriter();
    422. 			} catch (IOException e) {
    423. 				// TODO Auto-generated catch block
    424. 				e.printStackTrace();
    425. 			}
    426. 			wrt.write(str);
    427. 		}
    428. 		return "";
    429. 	}
    431. 	public Connection getConn()
    432. 	{
    433. 		try
    434. 		{
    435. 			if(conn==null||conn.isClosed()){
    437. 				Class.forName("com.mysql.cj.jdbc.Driver");
    438. 				conn = DriverManager.getConnection("jdbc:mysql://192.168.182.129:3306/jsp_jzfw_site?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8","root","123456");
    440. //						 Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
    441. //			        	 conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;databaseName=jsp_jzfw_site","sa","sa123456");
    442. 			}}
    443. 		catch(Exception e)
    444. 		{
    445. 			e.printStackTrace();
    446. 		}
    447. 		return conn;
    448. 	}
    451. 	public int getInt(String sql)
    452. 	{
    453. 		int i = 0;
    454. 		try {
    455. 			Statement st = conn.createStatement();
    456. 			ResultSet rs = st.executeQuery(sql);
    457. 			if(rs.next())
    458. 			{
    459. 				i = rs.getInt(1);
    460. 			}
    461. 			st.close();
    462. 		} catch (SQLException e) {
    463. 			// TODO Auto-generated catch block
    464. 			e.printStackTrace();
    465. 		}
    466. 		return i;
    467. 	}
    469. 	public double getDouble(String sql)
    470. 	{
    471. 		double i = 0;
    472. 		try {
    473. 			Statement st = conn.createStatement();
    474. 			ResultSet rs = st.executeQuery(sql);
    475. 			if(rs.next())
    476. 			{
    477. 				i = rs.getDouble(1);
    479. 			}
    480. 			st.close();
    481. 		} catch (SQLException e) {
    482. 			// TODO Auto-generated catch block
    483. 			e.printStackTrace();
    484. 		}
    485. 		return i;
    486. 	}
    488. 	public void commOper(String sql)
    489. 	{
    490. 		System.out.println(sql);
    491. 		try {
    492. 			Statement st = conn.createStatement();
    493. 			st.execute(sql);
    494. 			st.close();
    495. 		} catch (SQLException e) {
    496. 			// TODO Auto-generated catch block
    497. 			e.printStackTrace();
    498. 		}
    499. 	}
    501. 	public void commOperSqls(ArrayList<String> sql)
    502. 	{
    504. 		try {
    505. 			conn.setAutoCommit(false);
    506. 			for(int i=0;i<sql.size();i++)
    507. 			{
    508. 				Statement st = conn.createStatement();
    509. 				System.out.println(sql.get(i));
    510. 				st.execute(sql.get(i));
    511. 				st.close();
    512. 			}
    513. 			conn.commit();
    514. 		} catch (SQLException e) {
    515. 			try {
    516. 				conn.rollback();
    517. 			} catch (SQLException e1) {
    518. 				e1.printStackTrace();
    519. 			}
    520. 			e.printStackTrace();
    521. 		}finally{
    522. 			try {
    523. 				conn.setAutoCommit(true);
    524. 			} catch (SQLException e) {
    525. 				e.printStackTrace();
    526. 			}
    527. 		}
    528. 	}
    531. 	public List<HashMap> select(String sql)
    532. 	{
    533. 		System.out.println(sql);
    534. 		List<HashMap> list = new ArrayList();
    535. 		try {
    536. 			Statement st = conn.createStatement();
    537. 			ResultSet rs = st.executeQuery(sql);
    538. 			ResultSetMetaData rsmd = rs.getMetaData();
    539.  
    540. 			while(rs.next())
    541. 			{
    542. 				HashMap map = new HashMap();
    543. 				int i = rsmd.getColumnCount();
    544. 				for(int j=1;j<=i;j++)
    545. 				{
    546. 					if(!rsmd.getColumnName(j).equals("ID"))
    547. 					{
    548. 						String str = rs.getString(j)==null?"": rs.getString(j);
    549. 						if(str.equals("null"))str = "";
    550. 						map.put(rsmd.getColumnName(j), str);
    551. 					}
    552. 					else
    553. 						map.put("id", rs.getString(j));
    554. 				}
    555. 				list.add(map);
    556. 			}
    557. 			rs.close();
    558. 			st.close();
    559. 		} catch (SQLException e) {
    560. 			// TODO Auto-generated catch block
    561.  
    562. 			if(sql.equals("show tables"))
    563. 				list = select("select table_name from   INFORMATION_SCHEMA.tables");
    564. 			else
    565. 				e.printStackTrace();
    566. 		}
    567. 		return list;
    568. 	}
    569.  
    570.  
    571. 	public List<List> selectforlist(String sql)
    572. 	{
    573. 		List<List> list = new ArrayList();
    574. 		try {
    575. 			Statement st = conn.createStatement();
    576. 			ResultSet rs = st.executeQuery(sql);
    577. 			ResultSetMetaData rsmd = rs.getMetaData();
    578.  
    579. 			while(rs.next())
    580. 			{
    581. 				List<String> list2 = new ArrayList();
    582. 				int i = rsmd.getColumnCount();
    583. 				for(int j=1;j<=i;j++)
    584. 				{
    585. 					if(!rsmd.getColumnName(j).equals("ID"))
    586. 					{
    587. 						String str = rs.getString(j)==null?"": rs.getString(j);
    588. 						if(str.equals("null"))str = "";
    589. 						list2.add( str);
    590. 					}
    591. 					else
    592. 						list2.add(rs.getString(j));
    593. 				}
    594. 				list.add(list2);
    595. 			}
    596. 			rs.close();
    597. 			st.close();
    598. 		} catch (SQLException e) {
    599. 			// TODO Auto-generated catch block
    600. 			e.printStackTrace();
    601. 		}
    602. 		return list;
    603. 	}
    604.  
    605.  
    606. 	public void close()
    607. 	{
    608.  
    609. 	}
    610.  
    611. 	/**
    612. 	 * 执行一条查询sql,以 List<hashmap> 的形式返回查询的记录，记录条数，和从第几条开始，由参数决定，主要用于翻页
    613. 	 * pageno 页码  rowsize 每页的条数
    614. 	 */
    615. 	public List<HashMap> select(String sql, int pageno, int rowsize) {
    616. 		List<HashMap> list=new ArrayList<HashMap>();
    617. 		List<HashMap> mlist=new ArrayList<HashMap>();
    618. 		try{
    619. 			list=this.select(sql);
    620. 			int min = (pageno-1)*rowsize;
    621. 			int max = pageno*rowsize;
    622.  
    623. 			for(int i=0;i<list.size();i++)
    624. 			{
    625.  
    626. 				if(!(i<min||i>(max-1)))
    627. 				{
    628. 					mlist.add(list.get(i));
    629. 				}
    630. 			}
    631. 		}catch(RuntimeException re){
    632. 			re.printStackTrace();
    633. 			throw re;
    634. 		}
    635.  
    636. 		return mlist;
    637. 	}
    638.  
    639. 	public static void main(String[] args) {
    640. 	}
    641. }
    642.

    源码获取：俺的博客首页 "资源" 里下载！

  • 相关阅读:
    局部线性嵌入LLE算法--学习笔记
    JDBC —— 数据库连接
    vision transformer的计算复杂度
    Express 基础操作和详解
    面试：并发
    Vue.js 页面加载时触发函数
    前端——Layui的导航栏与tab页联动
    有了PySnooper，不用print、不用debug轻松查找问题所在！
    法律战爆发：“币安退出俄罗斯引发冲击波“
    收藏品集团怎样应用自动化程序实现降本增效
  • 原文地址：https://blog.csdn.net/m0_66863468/article/details/125466412