你的位置:首页 > Java教程

[Java教程]9_Jvn框架之实现ORM持久层save操作(第九讲)


本次博客讲的内容:

场景:以前使用JDBC的时候对于jbdc相信很多人都做了不同的封装,因为纯JDBC的操作还是相对来说比较繁琐的。所以今天我们也来封装一下JBDC

        把它集成到我们的Jvn框架里面。

解决思路:

  不清楚可以直接看下面的代码。

      1,操作数据库前引入连接池概念 druid。连接池的好处,相信大家都懂啦。

  2,引入ThreadLocal。泛型指定Connection,用来存放链接。该类可以保证你在一个线程里面获取得到的是同一个Connection。

  3,创建JDBC类 存放 driver  user pasword jdbcUrl.

  4,  创建pool接口,定义 getConnection方法,面向接口思想,以后可能有c3p0,druid等等连接池。

  5,定义接口实现类DruidPool,定义属性 ThreadLocal<Connection> connections,初始化创建于数据库链接,提供getConnection()方法,获取时,先判断

  connections.get()是否空,如果为空,从Druid连接池获取,然后在connections.set(conn);

  6,创建DB类,里面封装对JDBC操作的封装. 

  7,将实体类跟DAO合并,定义父类JvnModel ,里面有两属性,String = tableName(对应表名),Map = attrs(数据库字段),定义save(),update(),delete(),find()

  等方法,本次实现save()方法(这里调用的是DB.save),即保存一条数据方法,其他的下集讲解。

  8,对于save()操作的分析,Mysql增加一条数据操作为 insert into user (name,age,school) values(?,?,?)这种结构 分析为如下三步,

    insert into user (key) values(wenhao)根据要插入的参数有多少个生成多少个key参数多少个问号:

    第一步 key=name,age, school  去除掉最后一个“逗号”。

    第二步 wenhao = ?,?, ?,    去除最后一个逗号    

    然后拼接起来  insert into user (name,age,school) values(?,?,?)  在执行插入对应参数值。

    得到insert into user (name,age,school) values(everxs,100,清华) 

  9,定义@Model注解类,给对应的model注解。

  10,启动扫描有@Model注解的类添加进Map里面 

代码示例:

jdbc:

public class Jdbc {	private String driver;	private String user;	private String password;	private String jdbcUrl;		public Jdbc() {			}				public Jdbc(String driver, String user, String password, String jdbcUrl) {		super();		this.driver = driver;		this.user = user;		this.password = password;		this.jdbcUrl = jdbcUrl;	}	public String getDriver() {		return driver;	}	public void setDriver(String driver) {		this.driver = driver;	}	public String getUser() {		return user;	}	public void setUser(String user) {		this.user = user;	}	public String getPassword() {		return password;	}	public void setPassword(String password) {		this.password = password;	}	public String getJdbcUrl() {		return jdbcUrl;	}	public void setJdbcUrl(String jdbcUrl) {		this.jdbcUrl = jdbcUrl;	}	}

pool接口:

public interface Pool {	public Connection getConnection();}

DruidPool实现类:

/** * druid连接池 * @author everxs * */public class DruidPool implements Pool{	private static DruidDataSource dataSource;	private ThreadLocal<Connection> connections = new ThreadLocal<Connection>();	/**	 * 创建好druid	 * @param jdbc	 */	public DruidPool(Jdbc jdbc) {			dataSource = new DruidDataSource();		dataSource.setDriverClassName(jdbc.getDriver());		dataSource.setUsername(jdbc.getUser());		dataSource.setPassword(jdbc.getPassword());		dataSource.setUrl(jdbc.getJdbcUrl());		dataSource.setPoolPreparedStatements(true);		dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);		dataSource.setInitialSize(5);		dataSource.setMinIdle(1);		dataSource.setMaxActive(10);		dataSource.setMaxWait(60000);		// 启用监控统计功能		 try {			dataSource.setFilters("stat");		} catch (SQLException e) {				e.printStackTrace();		}// for mysql		 dataSource.setPoolPreparedStatements(false);	}	public DruidPool() {			}	/**	 * 获取一个连接	 * @return	 */	public synchronized Connection getConnection() {		Connection conn = connections.get();		System.out.println("进入 :"+conn);				try {			if(conn==null||conn.isClosed()){								conn = dataSource.getConnection();				System.out.println("null 后:"+conn);				connections.set(conn);			}					} catch (Exception e) {			throw new RuntimeException(e);		}		return conn;	}}

JvnModel类:

public class JvnModel<T extends JvnModel> {	private Map<String,Object> attrs = new HashMap<String, Object>();	private String tableName = JvnConfig.CONSTANT.getTable().getTable(this.getClass());		/**	 * 保存操作	 * @return	 */	public int save(){		int i = save(JvnConfig.pool.getConnection());		return i;	}		/**	 * 保存操作	 * @return	 */	public int save(Connection conn){				int i = Db.save(tableName, this);			return i;		}	public Map<String, Object> getAttrs() {		return attrs;	}	public void setAttrs(Map<String, Object> attrs) {		this.attrs = attrs;	}	public String getTableName() {		return tableName;	}	public void setTableName(String tableName) {		this.tableName = tableName;	}		public void set(String attr,Object value){		attrs.put(attr, value);	}		public Object get(String attr){		return attrs.get(attr);	}}

DB类:

/** * 数据库查询通用类 * @author everxs * */public class Db {	/**	 * 保存操作	 * @return	 */	public static int save(String tableName,JvnModel model){		return save( tableName, model,JvnConfig.pool.getConnection());	}		/**	 * 保存操作	 * @return	 */	public static int save(String tableName,JvnModel model,Connection conn){		int result= -1;		PreparedStatement ps= null;		ResultSet rs =null;		try{			String keys="";			String wenhao = "";			Object values[]=new String[model.getAttrs().size()];			int i = 0;			Map<String,String>strMap = MapKit.toStringMap(model.getAttrs());			for(String attr : strMap.keySet()){				keys = keys+attr+",";				wenhao = wenhao+"?,";				values[i] = strMap.get(attr);				i++;							}			if(keys.endsWith(",")){				keys = keys.substring(0,keys.length()-1);			}			if(wenhao.endsWith(",")){				wenhao = wenhao.substring(0,wenhao.length()-1);			}						String sql = "insert into "+tableName+"("+keys+")values("+wenhao+")";			ps = conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);								for (i = 0; i < values.length; i++) {				ps.setObject(i + 1, values[i]);			}									// 执行操作			result = ps.executeUpdate();			rs = ps.getGeneratedKeys();		   if (rs.next()) {         //知其仅有一列,故获取第一列         Long id = rs.getLong(1);         model.set("id", id);		   }					}catch(Exception e){			throw new RuntimeException(e);		}finally{			if(rs!=null){				try {					rs.close();				} catch (SQLException e) {					// TODO Auto-generated catch block					e.printStackTrace();				}			}			if(ps!=null){				try {					ps.close();				} catch (SQLException e) {					e.printStackTrace();				}			}			try {				if(conn!=null&&conn.getAutoCommit()){									conn.close();							}			} catch (Exception e) {				e.printStackTrace();			}				}		return result;	}									}

Model注解:

/** * 注解实体类 * @author everxs * */@Retention(RetentionPolicy.RUNTIME)public @interface Model {		String name();	}

扫描类代码:

	public static void scanClass(Constant constant){		//拿到classes绝对路劲		String path = ScanKit.class.getClassLoader().getResource("").getPath();		//得到类的全名称 例如: con.everxs.test.TestController.class		List<String> listClass= FileKit.listClassFileAbsolutePath(path);		for(String clazzStr : listClass){			try {				//找到这个类全名称的Class				Class clazz = Class.forName(clazzStr);								if(clazz!=null){					Controller controller= (Controller) clazz.getAnnotation(Controller.class);						Model model = (Model) clazz.getAnnotation(Model.class);					if(controller!=null){						constant.setRoute(controller.space(), clazz);					}					if(model!=null){						constant.getTable().setTable(clazz, model.name());					}							}			} catch (Exception e) {				System.out.println("找不到类文件");			}		}	}

测试 Member类:

@Model(name = "member")public class Member extends JvnModel<Member>{}

测试Controller:

@Controller(space = "/member")public class MemberController extends JvnController{	public void save(){				Member member = new Member();		member.set("name", "everxs");		member.set("age", 18);		member.save();				renderString("增加成功!");	}}

结果:保存数据库成功。

 

关于Jvn:

    框架命名为Jvn,博客里有连续的开发视频,每一篇博文都是一个知识点,关于框架的介绍和学习,可以从我博客第一讲开始看起;

    本次内容的源码与视频下载地址:http://pan.baidu.com/s/1i3iY9fv

    Jvn框架QQ交流群:399603805

    博客首页:http://www.cnblogs.com/everxs/

    永远的八哥...