dao 全部以 class 的形式创建,加上MarsDao注解,如下图所示:

    1. @MarsDao("testDao")
    2. public class TestDao {
    3. /**
    4. * 查询
    5. * @return
    6. */
    7. public List<Map<String,Object>> selectList(){
    8. try {
    9. return JdbcTemplete.get("dataSource").selectList("select * from userinfo");
    10. } catch (Exception e){
    11. e.printStackTrace();
    12. }
    13. return null;
    14. }
    15. /**
    16. * 插入
    17. * @param demoEntity
    18. * @return
    19. */
    20. public int insert(DemoEntity demoEntity){
    21. try {
    22. /* 增删改 都是调用update方法 */
    23. return JdbcTemplete.get("dataSource").update("sql语句",demoEntity);
    24. } catch (Exception e){
    25. e.printStackTrace();
    26. }
    27. return -1;
    28. }
    29. /**
    30. * sql传参
    31. * @param demoEntity
    32. * @return
    33. */
    34. public int update(DemoEntity demoEntity){
    35. try {
    36. /* 这种传参方法 有sql注入的风险 */
    37. return JdbcTemplete.get("dataSource").update(
    38. "update 表名 set 字段名 = {参数对象中的的字段名}"
    39. ,demoEntity);
    40. } catch (Exception e){
    41. e.printStackTrace();
    42. }
    43. return -1;
    44. }
    45. /**
    46. * sql传参
    47. * @param demoEntity
    48. * @return
    49. */
    50. public int delete(DemoEntity demoEntity){
    51. try {
    52. List<Object> params = new ArrayList<Object>();
    53. params.add(demoEntity.getName());
    54. /* 这种传参方法 没有sql注入的风险,但是不够清晰 */
    55. return JdbcTemplete.get("dataSource").update(
    56. "update 表名 set 字段名 = ?"
    57. ,params.toArray());
    58. } catch (Exception e){
    59. e.printStackTrace();
    60. }
    61. return -1;
    62. }
    63. }

    dao层的方法上 可以用 DataSource(name=”数据源name”) 注解 去指定要用的数据源,如果只有一个数据源,则不需要指定

    generated by haroopad