001/* 002 * JKNIV, whinstone one contract to access your database. 003 * 004 * Copyright (C) 2017, the original author or authors. 005 * 006 * This library is free software; you can redistribute it and/or 007 * modify it under the terms of the GNU Lesser General Public 008 * License as published by the Free Software Foundation; either 009 * version 2.1 of the License. 010 * 011 * This library is distributed in the hope that it will be useful, 012 * but WITHOUT ANY WARRANTY; without even the implied warranty of 013 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 014 * Lesser General Public License for more details. 015 * 016 * You should have received a copy of the GNU Lesser General Public 017 * License along with this library; if not, write to the Free Software Foundation, Inc., 018 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA 019 */ 020package net.sf.jkniv.whinstone.jpa2.commands; 021 022import java.sql.ResultSet; 023 024import net.sf.jkniv.exception.HandleableException; 025import net.sf.jkniv.whinstone.Queryable; 026import net.sf.jkniv.whinstone.commands.Command; 027import net.sf.jkniv.whinstone.commands.CommandHandler; 028import net.sf.jkniv.whinstone.jpa2.statement.JpaStatementAdapter; 029 030public class DefaultJpaCommand implements Command 031{ 032 protected final Queryable queryable; 033 protected JpaStatementAdapter<Number, ResultSet> stmt; 034 protected HandleableException handlerException; 035 036 public DefaultJpaCommand(Queryable queryable) 037 { 038 super(); 039 this.queryable = queryable; 040 } 041 042 @Override 043 public <T> Command with(T stmt) 044 { 045 this.stmt = (JpaStatementAdapter<Number, ResultSet>) stmt; 046 return this; 047 } 048 049 @Override 050 public Command with(HandleableException handlerException) 051 { 052 this.handlerException = handlerException; 053 return this; 054 } 055 056 @Override 057 public Command with(CommandHandler commandHandler) 058 { 059 return this; 060 } 061 062 @Override 063 @SuppressWarnings("unchecked") 064 public <T> T execute() 065 { 066 Integer rows = 0; 067 if(queryable.isTypeOfBulk()) 068 rows = queryable.bind(stmt).onBulk(); 069 else 070 { 071 queryable.bind(stmt).on(); 072 rows = stmt.execute(); 073 } 074 return (T) rows; 075 } 076}