beetlsql

爱被打了一巴掌 2023-10-11 15:04 12阅读 0赞

package beetlsql;
    
    import java.io.InputStream;
    import java.util.Date;
    import java.util.List;
    import java.util.Properties;
    
    import org.beetl.sql.core.ClasspathLoader;
    import org.beetl.sql.core.ConnectionSource;
    import org.beetl.sql.core.ConnectionSourceHelper;
    import org.beetl.sql.core.Interceptor;
    import org.beetl.sql.core.SQLLoader;
    import org.beetl.sql.core.SQLManager;
    import org.beetl.sql.core.SQLReady;
    import org.beetl.sql.core.UnderlinedNameConversion;
    import org.beetl.sql.core.db.DBStyle;
    import org.beetl.sql.core.db.MySqlStyle;
    import org.beetl.sql.core.query.Query;
    import org.beetl.sql.ext.DebugInterceptor;
    
    import beetlsql.model.User;
    
    public class DBUtils {
    
    	public static void main(String[] args) {
    //		add();
    //		del();
    //		update();
    		query();
    //		query2();
    //		query3();
    //		queryForJDBC();
    	}
    
    	public static void add() {
    		SQLManager sqlManager = getSQLManager();
    		// 使用内置的生成的sql 新增用户，如果需要获取主键，可以传入KeyHolder
    		User user = new User();
    		user.setAge(25);
    		user.setName("张盛13333333");
    		user.setCreateDate(new Date());
    		sqlManager.insert(user);
    	}
    	
    	public static void del() {
    		SQLManager sqlManager = getSQLManager();
    		User user = new User();
    		user.setId(6);
    		sqlManager.deleteObject(user);
    	}
    	
    	public static void update() {
    		SQLManager sqlManager = getSQLManager();
    		User user = new User();
    		user.setId(6);
    		user.setName("张盛111111");
    		user.setCreateDate(new Date());
    		sqlManager.updateTemplateById(user);
    	}
    	
    	public static void query() {
    		SQLManager sqlManager = SQLManageFactory.getSQLManager();
    		User user = new User();
    		user.setName("xiandafu");
    		List<User> list = sqlManager.template(user);
    		list.forEach(item -> System.out.println(item));
    	}
    	
    	public static void query2() {
    		SQLManager sqlManager = getSQLManager();
    		Query userQuery = sqlManager.query(User.class);
    		List<User> users = userQuery.andEq("name","张盛").select();
    		users.forEach(item -> System.out.println(item));
    	}
    	
    	public static void query3() {
    		使用user.md 文件里的select语句
    		SQLManager sqlManager = getSQLManager();
    		User query = new User();
    		query.setName("xiandafu");
    		List<User> users = sqlManager.select("user.select",User.class,query);
    		users.forEach(item -> System.out.println(item));
    	}
    	
    	public static void queryForJDBC() {
    		使用user.md 文件里的select语句
    		SQLManager sqlManager = getSQLManager();
    		String sql = "select u.*,a.name as address_name from user u left join address a on u.address_id = a.id";
    		List<User> users = sqlManager.execute(new SQLReady(sql),User.class);
    		users.forEach(item -> System.out.println(item));
    	}
    
    	public static SQLManager getSQLManager() {
    		Properties prop = getProp();
    		ConnectionSource source = ConnectionSourceHelper.getSimple(
    				prop.getProperty("driver"),
    				prop.getProperty("url"), 
    				prop.getProperty("username"), 
    				prop.getProperty("password"));
    		DBStyle mysql = new MySqlStyle();
    
    		// sql语句放在classpagth的/sql 目录下
    		SQLLoader loader = new ClasspathLoader("/sql");
    
    		// 数据库命名跟java命名一样，所以采用DefaultNameConversion，还有一个是UnderlinedNameConversion，下划线风格的，
    		UnderlinedNameConversion nc = new UnderlinedNameConversion();
    
    		// 最后，创建一个SQLManager,DebugInterceptor 不是必须的，但可以通过它查看sql执行情况
    		SQLManager sqlManager = new SQLManager(mysql, loader, source, nc, new Interceptor[] { new DebugInterceptor() });
    		return sqlManager;
    	}
    
    	public static Properties getProp() {
    		Properties prop = new Properties();
    		try (InputStream in = DBUtils.class.getResourceAsStream("/jdbc.properties")) {
    			prop.load(in);
    			in.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return prop;
    	}
    }